From c5ff14cad77d1502154a51069e56f07dcf60d4b9 Mon Sep 17 00:00:00 2001 From: zgg2001 <72535659+zgg2001@users.noreply.github.com> Date: Fri, 19 Jan 2024 11:16:38 +0800 Subject: [PATCH] bugfix: fix panic when sync reader needed to exit (#760) --- internal/reader/sync_standalone_reader.go | 1 - 1 file changed, 1 deletion(-) diff --git a/internal/reader/sync_standalone_reader.go b/internal/reader/sync_standalone_reader.go index 8c2eae17..5ca14b52 100644 --- 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