pub struct AeronFragmentClosureAssembler { /* private fields */ }Implementations§
Source§impl AeronFragmentClosureAssembler
impl AeronFragmentClosureAssembler
pub fn new() -> Result<Self, AeronCError>
Sourcepub fn poll<P: FragmentAssemblable, T>(
&mut self,
pollable: &P,
ctx: &mut T,
func: fn(&mut T, &[u8], AeronHeader),
fragment_limit: usize,
) -> Result<i32, AeronCError>
pub fn poll<P: FragmentAssemblable, T>( &mut self, pollable: &P, ctx: &mut T, func: fn(&mut T, &[u8], AeronHeader), fragment_limit: usize, ) -> Result<i32, AeronCError>
Poll pollable (a subscription or persistent subscription), dispatching each
reassembled message to func. ctx is borrowed only for the duration of the call.
Returns the fragment count from the underlying poll.
Auto Trait Implementations§
impl Freeze for AeronFragmentClosureAssembler
impl !RefUnwindSafe for AeronFragmentClosureAssembler
impl !Send for AeronFragmentClosureAssembler
impl !Sync for AeronFragmentClosureAssembler
impl Unpin for AeronFragmentClosureAssembler
impl UnsafeUnpin for AeronFragmentClosureAssembler
impl !UnwindSafe for AeronFragmentClosureAssembler
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more