Does consumer.next is cancellation-safe method?

[henry42]

I am trying to use
select! { delivery = consumer.next(), other future => ... }
to fetch new messages. I have tried it, and it worked like a charm.
However, I want to make sure that it is a cancellation-safe method where I won't lose any messages. Thank you.

[Keruspe]

Any reason why you're not storing the future returned by consumer.next()?
This way it will be cancellation-safe for sure

[henry42]

Any reason why you're not storing the future returned by consumer.next()? This way it will be cancellation-safe for sure

Thanks for the reply. If the consumer encounters other events (such as timeout or sigterm), it may exit.