Method Next

jetstream/pull.go:41–41

Next retrieves next message on a stream. If MessagesContext is closed (either stopped or drained), Next will return ErrMsgIteratorClosed error. An optional timeout or context can be provided using NextOpt options. If none are provided, Next will block indefinitely until a message is available, itera

(opts ...NextOpt)

		// options. If none are provided, Next will block indefinitely until a
		// message is available, iterator is closed or a heartbeat error occurs.
		Next(opts ...NextOpt) (Msg, error)

		// Stop unsubscribes from the stream and cancels subscription. Calling
		// Next after calling Stop will return ErrMsgIteratorClosed error.