stan.py icon indicating copy to clipboard operation
stan.py copied to clipboard

Published 20 hours ago • verified publisher icon nats-io

Drain mode

Open alpmdog opened this issue 5 years ago • 1 comments

Is there a way to figure out if a subscriber has drained all the messages in a given channel and is caught up? I would still want to process all the messages, but change behavior once have seen all the messages in the channel.

alpmdog avatar Apr 04 '19 19:04 alpmdog

In this PR I’m adding a ‘pending_queue_size’ method to the subscription so that it is possible to check how far behind is the consumer https://github.com/nats-io/asyncio-nats-streaming/pull/21

wallyqs avatar Apr 05 '19 09:04 wallyqs