Function rusteron_client::bindings::aeron_image_bounded_controlled_poll
source ยท pub unsafe extern "C" fn aeron_image_bounded_controlled_poll(
image: *mut aeron_image_t,
handler: aeron_controlled_fragment_handler_t,
clientd: *mut c_void,
limit_position: i64,
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 or the maximum position 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 limit_position to consume messages up to. @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.