Function PullMaxMessagesWithBytesLimit

jetstream/jetstream_options.go:172–174

PullMaxMessagesWithBytesLimit limits the number of messages to be buffered in the client. Additionally, it sets the maximum size a single fetch request can have. Note that this will not limit the total size of messages buffered in the client, but rather can serve as a way to limit what nats server w

(maxMessages, byteLimit int)

// PullMaxMessagesWithBytesLimit implements both PullConsumeOpt and
// PullMessagesOpt, allowing it to configure Consumer.Consume and Consumer.Messages.
func PullMaxMessagesWithBytesLimit(maxMessages, byteLimit int) pullMaxMessagesWithBytesLimit {
	return pullMaxMessagesWithBytesLimit{maxMessages, byteLimit}
}

func (m pullMaxMessagesWithBytesLimit) configureConsume(opts *consumeOpts) error {
	if m.maxMessages <= 0 {