Update stream.go

simon28082 · web-flow · commit 4d3a4e89fe24 · 2024-10-17T21:57:05.000+08:00
Change maxSize type
diff --git 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() > int(st.MaxSize) {
+			if batch.LenNoPadding() > uint64(st.MaxSize) {
 				break loop
 			}
 			select {

Original file line number	Diff line number	Diff line change
`@@ -323,7 +323,7 @@ func (st *Stream) streamKVs(ctx context.Context) error {`
`323`	`323`	`// Send the batch immediately if it already exceeds the maximum allowed size.`
`324`	`324`	`// If the size of the batch exceeds maxStreamSize, break from the loop to`
`325`	`325`	`// avoid creating a batch that is so big that certain limits are reached.`
`326`		`- if batch.LenNoPadding() > int(st.MaxSize) {`
	`326`	`+ if batch.LenNoPadding() > uint64(st.MaxSize) {`
`327`	`327`	`break loop`
`328`	`328`	`}`
`329`	`329`	`select {`