Struct worker_plus::MessageBatch
source · pub struct MessageBatch<T> { /* private fields */ }
Implementations§
source§impl<T> MessageBatch<T>
impl<T> MessageBatch<T>
pub fn new(message_batch_sys: MessageBatchSys) -> Self
source§impl<T> MessageBatch<T>
impl<T> MessageBatch<T>
sourcepub fn iter(&self) -> MessageIter<'_, T> ⓘwhere
T: DeserializeOwned,
pub fn iter(&self) -> MessageIter<'_, T> ⓘwhere
T: DeserializeOwned,
Iterator that deserializes messages in the message batch. Ordering of messages is not guaranteed.