Trait PayloadBatch 

pub trait PayloadBatch<'buf> {
    // Required methods
    fn next_payload(&mut self) -> Option<RawPayload<'buf>>;
    fn ack(&self) -> &AckRef;
}

One poll’s worth of borrowed payloads. Streaming — payloads are handed out one at a time, and every payload shares the batch lifetime 'buf. The batch carries exactly one AckRef, issued by the lane through its AckIssuer; records derived from these payloads clone it.

Required Methods

fn next_payload(&mut self) -> Option<RawPayload<'buf>>

The next payload, or None when the batch is exhausted.

fn ack(&self) -> &AckRef

The acknowledgement handle covering every payload in this batch.

Implementations on Foreign Types

impl<'a> PayloadBatch<'a> for KafkaBatch<'a>

fn next_payload(&mut self) -> Option<RawPayload<'a>>

fn ack(&self) -> &AckRef

Implementors