rusteron_client

Trait AeronControlledFragmentHandlerCallback

Source 
pub trait AeronControlledFragmentHandlerCallback {
    // Required method
    fn handle_aeron_controlled_fragment_handler(
        &mut self,
        buffer: &'static [u8],
        header: AeronHeader,
    ) -> aeron_controlled_fragment_handler_action_t;
}
Expand description

Callback for handling fragments of data being read from a log.

Handler for reading data that is coming from a log buffer. The frame will either contain a whole message or a fragment of a message to be reassembled. Messages are fragmented if greater than the frame for MTU in length.

@param clientd passed to the controlled poll function. @param buffer containing the data. @param length of the data in bytes. @param header representing the meta data for the data. @return The action to be taken with regard to the stream position after the callback.

(note you must copy any arguments that you use afterwards even those with static lifetimes)

Required Methods§

Source

fn handle_aeron_controlled_fragment_handler( &mut self, buffer: &'static [u8], header: AeronHeader, ) -> aeron_controlled_fragment_handler_action_t

Implementors§