- Introduced `streamDone` channel to signal the completion of streaming goroutines. - Updated `processStreamingChunks` to incorporate proper cleanup and defer close operations. - Ensured `streamWriter` and associated resources are released when streaming completes.