[FIXED] Invalid value of max_bytes in pull request

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>

jetstream/pull.go

@@ -420,13 +420,15 @@ func (s *pullSubscription) checkPending() {
 	if (s.pending.msgCount < s.consumeOpts.ThresholdMessages ||
 		(s.pending.byteCount < s.consumeOpts.ThresholdBytes && s.consumeOpts.MaxBytes != 0)) &&
 		atomic.LoadUint32(&s.fetchInProgress) == 0 {
-		var batchSize int
+
+		var batchSize, maxBytes int
 		if s.consumeOpts.MaxBytes == 0 {
 			// if using messages, calculate appropriate batch size
 			batchSize = s.consumeOpts.MaxMessages - s.pending.msgCount
 		} else {
 			// if using bytes, use the max value
 			batchSize = s.consumeOpts.MaxMessages
+			maxBytes = s.consumeOpts.MaxBytes - s.pending.byteCount
 		}
 		if s.consumeOpts.StopAfter > 0 {
 			batchSize = min(batchSize, s.consumeOpts.StopAfter-s.delivered-s.pending.msgCount)
@@ -435,7 +437,7 @@ func (s *pullSubscription) checkPending() {
 			s.fetchNext <- &pullRequest{
 				Expires:   s.consumeOpts.Expires,
 				Batch:     batchSize,
-				MaxBytes:  s.consumeOpts.MaxBytes - s.pending.byteCount,
+				MaxBytes:  maxBytes,
 				Heartbeat: s.consumeOpts.Heartbeat,
 			}