Function libaeron_sys::aeron_image_controlled_poll

pub unsafe extern "C" fn aeron_image_controlled_poll(
    image: *mut aeron_image_t,
    handler: aeron_controlled_fragment_handler_t,
    clientd: *mut c_void,
    fragment_limit: usize
) -> c_int

Poll for new messages in a stream. If new messages are found beyond the last consumed position then they will be delivered to the handler up to a limited number of fragments as specified.

Use a controlled fragment assembler to assemble messages which span multiple fragments.

@param image to poll. @param handler to which message fragments are delivered. @param clientd to pass to the handler. @param fragment_limit for the number of fragments to be consumed during one polling operation. @return the number of fragments that have been consumed or -1 for error.