Function rusteron_archive::bindings::aeron_archive_replay_merge_poll
source ยท pub unsafe extern "C" fn aeron_archive_replay_merge_poll(
replay_merge: *mut aeron_archive_replay_merge_t,
handler: aeron_fragment_handler_t,
clientd: *mut c_void,
fragment_limit: c_int,
) -> c_int
Expand description
Poll the image used for the merging replay and live stream. The aeron_archive_replay_merge_do_work will be called before the poll so that processing of the merge can be done.
@param replay_merge the replay_merge to process/poll @param handler the handler to call for incoming fragments @param clientd the clientd to provide to the handler @param fragment_limit the max number of fragments to process before returning @return >= 0 indicates the number of fragments processed, -1 for failure