Method MsgsTimeout

nats_iter.go:55–72

MsgsTimeout returns an iter.Seq2[*Msg, error] that can be used to iterate over messages. It can only be used with a subscription that has been created with SubscribeSync or QueueSubscribeSync, otherwise it will return an error on the first iteration. The iterator will block until a message is avail

(timeout time.Duration)

// reached. If the timeout is reached, the iterator will return nats.ErrTimeout
// but it will not be closed.
func (sub *Subscription) MsgsTimeout(timeout time.Duration) iter.Seq2[*Msg, error] {
	return func(yield func(*Msg, error) bool) {
		for {
			msg, err := sub.NextMsg(timeout)
			if err != nil {
				if !yield(nil, err) {
					return
				}
				if !errors.Is(err, ErrTimeout) {
					return
				}
			}
			if !yield(msg, nil) {
				return
			}
		}
	}
}