Function rusteron_client::bindings::aeron_subscription_poll
source ยท pub unsafe extern "C" fn aeron_subscription_poll(
subscription: *mut aeron_subscription_t,
handler: aeron_fragment_handler_t,
clientd: *mut c_void,
fragment_limit: usize,
) -> c_int
Expand description
Poll the images under the subscription for available message fragments.
Each fragment read will be a whole message if it is under MTU length. If larger than MTU then it will come as a series of fragments ordered within a session.
To assemble messages that span multiple fragments then use aeron_fragment_assembler_t.
@param subscription to poll. @param handler for handling each message fragment as it is read. @param fragment_limit number of message fragments to limit when polling across multiple images. @return the number of fragments received or -1 for error.