bugfix: fix panic when sync reader needed to exit (#760)

tair-opensource · Jan 19, 2024 · c5ff14c · c5ff14c
1 parent 0f374b1
commit c5ff14c
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/internal/reader/sync_standalone_reader.go b/internal/reader/sync_standalone_reader.go
@@ -108,7 +108,6 @@ func (r *syncStandaloneReader) StartRead(ctx context.Context) chan *entry.Entry
 			r.sendAOF(startOffset)
 		}
 		close(r.ch)
-		r.client.Close()
 	}()
 
 	return r.ch