Function rusteron_archive::bindings::aeron_image_poll

source ยท
pub unsafe extern "C" fn aeron_image_poll(
    image: *mut aeron_image_t,
    handler: aeron_fragment_handler_t,
    clientd: *mut c_void,
    fragment_limit: usize,
) -> c_int
Expand description

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 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.