We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 90cca0d commit 5eefff5Copy full SHA for 5eefff5
1 file changed
proxy/admin_stream_transfer.go
@@ -35,9 +35,14 @@ func startListener[T StreamRequestOrResponse](
35
) chan ValueWithError[T] {
36
targetStreamServerData := make(chan ValueWithError[T])
37
go func() {
38
+ defer close(targetStreamServerData)
39
for !shutdownChan.IsShutdown() {
40
req, err := receiver.Recv()
- targetStreamServerData <- ValueWithError[T]{val: req, err: err}
41
+ select {
42
+ case targetStreamServerData <- ValueWithError[T]{val: req, err: err}:
43
+ case <-shutdownChan.Channel():
44
+ return
45
+ }
46
}
47
}()
48
return targetStreamServerData
0 commit comments