From 14f5348e1dd906067c771c9fa9af97d3a3da4e4e Mon Sep 17 00:00:00 2001 From: yukun Date: Wed, 8 Dec 2021 09:16:23 +0800 Subject: [PATCH] [skip ci]Add comment for rocksmq reader (#12897) 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 d1642b6301..2da3ea77f7 100644 --- a/internal/util/rocksmq/client/rocksmq/reader_impl.go +++ b/internal/util/rocksmq/client/rocksmq/reader_impl.go @@ -69,6 +69,7 @@ func (r *reader) Next(ctx context.Context) (Message, error) { return msg, nil } +// HasNext check if there is a message available to read func (r *reader) HasNext() bool { return r.c.server.HasNext(r.topic, r.name, r.startMessageIDInclusive) }