We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4d3a4e8 commit ce00bcfCopy full SHA for ce00bcf
stream.go
@@ -323,7 +323,7 @@ func (st *Stream) streamKVs(ctx context.Context) error {
323
// Send the batch immediately if it already exceeds the maximum allowed size.
324
// If the size of the batch exceeds maxStreamSize, break from the loop to
325
// avoid creating a batch that is so big that certain limits are reached.
326
- if batch.LenNoPadding() > uint64(st.MaxSize) {
+ if uint64(batch.LenNoPadding()) > st.MaxSize {
327
break loop
328
}
329
select {
0 commit comments