Trait FragmentAssemblable 

pub trait FragmentAssemblable {
    // Required method
    fn poll_with_assembler(
        &self,
        assembler: Option<&Handler<AeronFragmentAssembler>>,
        fragment_limit: usize,
    ) -> Result<i32, AeronCError>;
}

A poll target whose raw fragments can be reassembled by AeronFragmentAssembler. Implemented for AeronSubscription here and for archive types in rusteron-archive.

Required Methods

fn poll_with_assembler( &self, assembler: Option<&Handler<AeronFragmentAssembler>>, fragment_limit: usize, ) -> Result<i32, AeronCError>

Implementors

impl FragmentAssemblable for AeronArchivePersistentSubscription

Route a persistent subscription through AeronFragmentClosureAssembler for API consistency with AeronSubscription. Note: the C aeron_archive_persistent_subscription_poll already reassembles fragments internally (via aeron_image_fragment_assembler_handler), so the delegate receives whole messages either way — the Rust assembler here is a pass-through. Prefer ps.poll_fn(handler, limit) directly unless you want the shared API.

impl FragmentAssemblable for AeronSubscription