[skip e2e]Add comment for pulsar reader (#14119)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
pull/14152/head
yukun 2021-12-24 11:01:19 +08:00 committed by GitHub
parent e3771bee3d
commit 94745ba3c3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions

View File

@ -26,6 +26,7 @@ func (pr *pulsarReader) Next(ctx context.Context) (Message, error) {
return &pulsarMessage{msg: pm}, nil
}
// HasNext check if there is any message available to read from the current position
func (pr *pulsarReader) HasNext() bool {
return pr.r.HasNext()
}