We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 811c86b commit 87f272dCopy full SHA for 87f272d
streams.go
@@ -134,7 +134,7 @@ func (w *baseStreamWriter[T]) processWriteQueue() {
134
case task := <-w.writeQueue:
135
w.writeStreamBytes(task.chunks, task.onDone)
136
case <-w.closed.Watch():
137
- // Drain any pending tasks - we don't want to send data after the trailer
+ // Drain any pending tasks - close sends a trailer and no data should be sent after that
138
for {
139
select {
140
case <-w.writeQueue:
0 commit comments