From 5c84992d4c8a8e67db7e25243ac001963ba4748d Mon Sep 17 00:00:00 2001 From: yukun Date: Wed, 8 Dec 2021 09:18:15 +0800 Subject: [PATCH] [skip ci]Add comment for rocksmq reader (#12898) Signed-off-by: fishpenguin --- internal/util/rocksmq/client/rocksmq/reader_impl.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/rocksmq/client/rocksmq/reader_impl.go b/internal/util/rocksmq/client/rocksmq/reader_impl.go index 2da3ea77f7..0f2d48c0e6 100644 --- a/internal/util/rocksmq/client/rocksmq/reader_impl.go +++ b/internal/util/rocksmq/client/rocksmq/reader_impl.go @@ -74,6 +74,7 @@ func (r *reader) HasNext() bool { return r.c.server.HasNext(r.topic, r.name, r.startMessageIDInclusive) } +// Close close the reader and stop the blocking reader func (r *reader) Close() { r.c.server.CloseReader(r.topic, r.name) }