feat: panic when EOF

Trendyol · Nov 6, 2023 · 9b981ce · 9b981ce
1 parent 77bf678
commit 9b981ce
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/stream/stream.go b/stream/stream.go
@@ -115,7 +115,7 @@ func (s *stream) listen() {
 func (s *stream) listenEnd() {
 	for endContext := range s.observer.ListenEnd() {
 		if endContext.Err != nil && errors.Is(endContext.Err, gocbcore.ErrSocketClosed) {
-			s.openStream(endContext.Event.VbID)
+			panic(endContext.Err)
 		} else {
 			s.activeStreams--
 			if s.activeStreams == 0 {