Struct AeronArchiveRecordingSubscriptionDescriptorPoller 

pub struct AeronArchiveRecordingSubscriptionDescriptorPoller { /* private fields */ }

Implementations

impl AeronArchiveRecordingSubscriptionDescriptorPoller

pub fn new_zeroed_on_heap() -> Self

creates zeroed struct where the underlying c struct is on the heap

pub fn new_zeroed_on_stack() -> Self

creates zeroed struct where the underlying c struct is on the stack (Use with care)

pub fn ctx(&self) -> AeronArchiveContext

pub fn subscription(&self) -> AeronSubscription

pub fn control_session_id(&self) -> i64

pub fn fragment_limit(&self) -> c_int

pub fn fragment_assembler(&self) -> AeronControlledFragmentAssembler

pub fn error_on_fragment(&self) -> bool

pub fn correlation_id(&self) -> i64

pub fn remaining_subscription_count(&self) -> i32

pub fn recording_subscription_descriptor_consumer( &self, ) -> aeron_archive_recording_subscription_descriptor_consumer_func_t

pub fn recording_subscription_descriptor_consumer_clientd(&self) -> *mut c_void

pub fn is_dispatch_complete(&self) -> bool

pub fn reset<AeronArchiveRecordingSubscriptionDescriptorConsumerFuncHandlerImpl: AeronArchiveRecordingSubscriptionDescriptorConsumerFuncCallback>( &self, correlation_id: i64, subscription_count: i32, recording_subscription_descriptor_consumer: Option<&Handler<AeronArchiveRecordingSubscriptionDescriptorConsumerFuncHandlerImpl>>, )

pub fn reset_fn<AeronArchiveRecordingSubscriptionDescriptorConsumerFuncHandlerImpl: FnMut(AeronArchiveRecordingSubscriptionDescriptor)>( &self, correlation_id: i64, subscription_count: i32, recording_subscription_descriptor_consumer: AeronArchiveRecordingSubscriptionDescriptorConsumerFuncHandlerImpl, )

Stack-borrowed closure (_fn variant): the FnMut closure lives on the caller’s stack and is borrowed for this call only — the callback fires synchronously inside the call, so nothing is heap-allocated, nothing is stored, and the closure may borrow local state. Prefer this over the retained Handler-based form on the hot path; only generated for callbacks the C client does not retain (i.e. not stored for later firing).

Panics

A panic inside the closure cannot unwind across the extern "C" callback boundary and aborts the process (since Rust 1.81). Return early instead of panicking in production fragment handlers.

pub fn poll(&self) -> Result<i32, AeronCError>

pub fn get_inner( &self, ) -> *mut aeron_archive_recording_subscription_descriptor_poller_t

pub unsafe fn get_inner_mut( &self, ) -> &mut aeron_archive_recording_subscription_descriptor_poller_t

Mutable access to the underlying C struct, minted from &self: nothing prevents two live &mut at once, so the caller must ensure exclusive access for the lifetime of the returned reference.

Safety

No other reference (& or &mut) to the underlying struct may be alive while the returned &mut is in use.

pub fn get_inner_ref( &self, ) -> &aeron_archive_recording_subscription_descriptor_poller_t

impl AeronArchiveRecordingSubscriptionDescriptorPoller

pub fn close(self) -> Result<(), AeronCError>

Closes this resource in the C client immediately; all clones of this handle become closed (their pointer is nulled) and must not be used.

Trait Implementations

impl Clone for AeronArchiveRecordingSubscriptionDescriptorPoller

fn clone(&self) -> AeronArchiveRecordingSubscriptionDescriptorPoller

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AeronArchiveRecordingSubscriptionDescriptorPoller

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Deref for AeronArchiveRecordingSubscriptionDescriptorPoller

type Target = aeron_archive_recording_subscription_descriptor_poller_stct

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl From<&AeronArchiveRecordingSubscriptionDescriptorPoller> for *mut aeron_archive_recording_subscription_descriptor_poller_t

fn from(value: &AeronArchiveRecordingSubscriptionDescriptorPoller) -> Self

Converts to this type from the input type.

impl From<*const aeron_archive_recording_subscription_descriptor_poller_stct> for AeronArchiveRecordingSubscriptionDescriptorPoller

fn from( value: *const aeron_archive_recording_subscription_descriptor_poller_t, ) -> Self

Converts to this type from the input type.

impl From<*mut aeron_archive_recording_subscription_descriptor_poller_stct> for AeronArchiveRecordingSubscriptionDescriptorPoller

fn from( value: *mut aeron_archive_recording_subscription_descriptor_poller_t, ) -> Self

Converts to this type from the input type.

impl From<AeronArchiveRecordingSubscriptionDescriptorPoller> for *mut aeron_archive_recording_subscription_descriptor_poller_t

fn from(value: AeronArchiveRecordingSubscriptionDescriptorPoller) -> Self

Converts to this type from the input type.

impl From<AeronArchiveRecordingSubscriptionDescriptorPoller> for aeron_archive_recording_subscription_descriptor_poller_t

fn from(value: AeronArchiveRecordingSubscriptionDescriptorPoller) -> Self

Converts to this type from the input type.

impl From<aeron_archive_recording_subscription_descriptor_poller_stct> for AeronArchiveRecordingSubscriptionDescriptorPoller

fn from(value: aeron_archive_recording_subscription_descriptor_poller_t) -> Self

Converts to this type from the input type.