Struct GetLastBuilder 

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

Builder for fetching last messages for multiple subjects.

Implementations

impl<T, SEQ, TIME> GetLastBuilder<T, SEQ, TIME>

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

pub fn subjects(self, subjects: Vec<String>) -> Self

Set the subjects to fetch last messages for.

Limits

• Maximum: 1024 subjects per request (server limit)
• Returns BatchFetchErrorKind::TooManySubjects if exceeded

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

Set the optional batch size.

Limits

• Maximum: 1000 messages per request (server limit)
• Returns BatchFetchErrorKind::BatchSizeTooLarge if exceeded

impl<T> GetLastBuilder<T, NoSeq, NoTime>

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

pub fn up_to_seq(self, seq: u64) -> GetLastBuilder<T, WithSeq, NoTime>

Set the sequence number to fetch up to (inclusive). This is mutually exclusive with up_to_time.

pub fn up_to_time( self, time: OffsetDateTime, ) -> GetLastBuilder<T, NoSeq, WithTime>

Set the time to fetch up to. This is mutually exclusive with up_to_seq.

impl<T, SEQ, TIME> GetLastBuilder<T, SEQ, TIME>

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

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

Send the request to get last messages and return a stream.