Trait AeronControlledFragmentHandlerCallback 

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

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

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

Implementors

impl AeronControlledFragmentHandlerCallback for AeronControlledFragmentAssembler

impl AeronControlledFragmentHandlerCallback for AeronControlledFragmentHandlerLogger

impl AeronControlledFragmentHandlerCallback for FnMutControlledMessageHandler

impl AeronControlledFragmentHandlerCallback for NoHandler

impl<F: FnMut(&[u8], AeronHeader) -> aeron_controlled_fragment_handler_action_t> AeronControlledFragmentHandlerCallback for F

Any closure with the matching signature is a callback: methods that retain it heap-allocate it into a Handler owned by the registering resource.

impl<T: AeronControlledFragmentHandlerCallback> AeronControlledFragmentHandlerCallback for Handler<T>

Pass an existing Handler clone anywhere a callback value is expected, e.g. to share one callback instance across several registrations.