Trait rusteron_media_driver::AeronBlockHandlerCallback

source · 
pub trait AeronBlockHandlerCallback {
    // Required method
    fn handle_aeron_block_handler(
        &mut self,
        buffer: &[u8],
        session_id: i32,
        term_id: i32,
    );
}
Expand description

Callback for handling a block of messages being read from a log.

@param clientd passed to the block poll function. @param buffer containing the block of message fragments. @param offset at which the block begins, including any frame headers. @param length of the block in bytes, including any frame headers that is aligned. @param session_id of the stream containing this block of message fragments. @param term_id of the stream containing this block of message fragments.

Required Methods§

source

fn handle_aeron_block_handler( &mut self, buffer: &[u8], session_id: i32, term_id: i32, )

Implementors§