Skip to content

Commit f4e6795

Browse files
authored
fix(destination): avoid blocking in synchronizedGetStream.Stop (#14621)
synchronizedGetStream.Stop incorrectly tried to send on an unbuffered channel. Now it closes the channel to avoid blocking.
1 parent 4b9d907 commit f4e6795

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

controller/api/destination/syncronized_get_stream.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,5 +71,5 @@ func (s *synchronizedGetStream) Start() {
7171
}
7272

7373
func (s *synchronizedGetStream) Stop() {
74-
s.done <- struct{}{}
74+
close(s.done)
7575
}

0 commit comments

Comments
 (0)