Function FetchMaxWait

jetstream/jetstream_options.go:517–526

FetchMaxWait sets custom timeout for fetching predefined batch of messages. If not provided, a default of 30 seconds will be used.

(timeout time.Duration)

//
// If not provided, a default of 30 seconds will be used.
func FetchMaxWait(timeout time.Duration) FetchOpt {
	return func(req *pullRequest) error {
		if timeout <= 0 {
			return fmt.Errorf("%w: timeout value must be greater than 0", ErrInvalidOption)
		}
		req.Expires = timeout
		req.maxWaitSet = true
		return nil
	}
}

// FetchHeartbeat sets custom heartbeat for individual fetch request. If a
// client does not receive a heartbeat message from a stream for more than 2