Struct nats::jetstream::NextRequest [−][src]
for getting next messages for pull based consumers.
Fields
batch: usize
The number of messages that are being requested to be delivered.
expires: Option<usize>
The optional number of nanoseconds that the server will store this next request for before forgetting about the pending batch size.
no_wait: Option<bool>
This optionally causes the server not to store this pending request at all, but when there are no messages to deliver will send a nil bytes message with a Status header of 404, this way you can know when you reached the end of the stream for example. A 409 is returned if the Consumer has reached MaxAckPending limits.
Trait Implementations
impl Clone for NextRequest
[src]
impl Clone for NextRequest
[src]fn clone(&self) -> NextRequest
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Copy for NextRequest
[src]
impl Copy for NextRequest
[src]impl Default for NextRequest
[src]
impl Default for NextRequest
[src]fn default() -> NextRequest
[src]
impl<'de> Deserialize<'de> for NextRequest
[src]
impl<'de> Deserialize<'de> for NextRequest
[src]fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Serialize for NextRequest
[src]
impl Serialize for NextRequest
[src]Auto Trait Implementations
impl RefUnwindSafe for NextRequest
impl RefUnwindSafe for NextRequest
impl Send for NextRequest
impl Send for NextRequest
impl Sync for NextRequest
impl Sync for NextRequest
impl Unpin for NextRequest
impl Unpin for NextRequest
impl UnwindSafe for NextRequest
impl UnwindSafe for NextRequest
Blanket Implementations
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]impl<T> Same<T> for T
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,