From ce00bcf52085208c1c3072dbaa2897b3ad632250 Mon Sep 17 00:00:00 2001 From: simon Date: Sun, 20 Oct 2024 13:24:01 +0800 Subject: [PATCH] fix typecheck --- stream.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/stream.go b/stream.go index 05ed4c214..d755ba99d 100644 --- a/stream.go +++ b/stream.go @@ -323,7 +323,7 @@ func (st *Stream) streamKVs(ctx context.Context) error { // Send the batch immediately if it already exceeds the maximum allowed size. // If the size of the batch exceeds maxStreamSize, break from the loop to // avoid creating a batch that is so big that certain limits are reached. - if batch.LenNoPadding() > uint64(st.MaxSize) { + if uint64(batch.LenNoPadding()) > st.MaxSize { break loop } select {