Method Next

jetstream/ordered.go:528–541

Next is used to retrieve the next message from the stream. This method will block until the message is retrieved or timeout is reached. It is not efficient to use Next with on an ordered consumer, as it will reset the consumer for each subsequent Fetch call. Consider using [Consumer.Consume] or [Co

(opts ...FetchOpt)

// reset the consumer for each subsequent Fetch call.
// Consider using [Consumer.Consume] or [Consumer.Messages] instead.
func (c *orderedConsumer) Next(opts ...FetchOpt) (Msg, error) {
	res, err := c.Fetch(1, opts...)
	if err != nil {
		return nil, err
	}
	msg := <-res.Messages()
	if msg != nil {
		return msg, nil
	}
	if res.Error() == nil {
		return nil, nats.ErrTimeout
	}
	return nil, res.Error()
}

func serialNumberFromConsumer(name string) int {
	if len(name) == 0 {