Module nats::jetstream::pull_subscription
source · [−]Expand description
Pull subscriptions
Structs
Iterator for handling batches of messages. Works like Iter
except stopping after
reading number of messages defined in batch_size
.
Interator that will endlessly wait for messages, unless no messages
or request timeout
is encountered.
A PullSubscription
pulls messages from Server triggered by client actions
Pull Subscription does nothing on itself. It has to explicitly request messages
using one of available
Iterator for handling batches of messages. Works like TimeoutIter
except stopping after
reading number of messages defined in batch_size
.
Iterator that retrieves messages unless no messages
or request timeout
is encountered, or
timeout is reached.
Iterator for handling batches of messages. Works like TryIter
except stopping after
reading number of messages defined in batch_size
.