Struct GetBatchBuilder 

pub struct GetBatchBuilder<T, SEQ = NoSeq, TIME = NoTime>
where
    T: ClientProvider + TimeoutProvider + RequestSender,
{ /* private fields */ }

Builder for batch fetching messages from a stream.

Implementations

impl<T, SEQ, TIME> GetBatchBuilder<T, SEQ, TIME>

where T: ClientProvider + TimeoutProvider + RequestSender + Clone + Send + Sync,

pub fn subject<S: Into<String>>(self, subject: S) -> Self

Set the subject filter (may include wildcards).

pub fn max_bytes(self, max_bytes: usize) -> Self

Set the maximum bytes to return.

impl<T> GetBatchBuilder<T, NoSeq, NoTime>

where T: ClientProvider + TimeoutProvider + RequestSender + Clone + Send + Sync,

pub fn sequence(self, seq: u64) -> GetBatchBuilder<T, WithSeq, NoTime>

Set the starting sequence number. This is mutually exclusive with start_time.

pub fn start_time( self, start_time: OffsetDateTime, ) -> GetBatchBuilder<T, NoSeq, WithTime>

Set the start time for time-based fetching. This is mutually exclusive with seq.

impl<T, SEQ, TIME> GetBatchBuilder<T, SEQ, TIME>

where T: ClientProvider + TimeoutProvider + RequestSender + Clone + Send + Sync,

pub async fn send(self) -> Result<BatchStream, BatchFetchError>

Send the batch fetch request and return a stream of messages.