Fix closed channel panic

Trendyol · Jun 16, 2023 · 1d08b3c · 1d08b3c
1 parent 1e4399d
commit 1d08b3c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/stream/stream.go b/stream/stream.go
@@ -109,7 +109,7 @@ func (s *stream) listen() {
 		default:
 		}
 	}
-	close(s.finishListenerBuffer)
+	s.finishListenerBuffer <- struct{}{}
 }
 
 func (s *stream) listenEnd() {