Struct AeronArchiveRecordingSubscriptionDescriptorPoller

pub struct AeronArchiveRecordingSubscriptionDescriptorPoller { /* private fields */ }

Implementations

impl AeronArchiveRecordingSubscriptionDescriptorPoller

pub fn new_zeroed() -> Result<Self, AeronCError>

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

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 close(&self) -> Result<i32, AeronCError>

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

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

NOTE: aeron must not store this closure and instead use it immediately. If not you will get undefined behaviour, use with care

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

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

Trait Implementations

impl Clone for AeronArchiveRecordingSubscriptionDescriptorPoller

fn clone(&self) -> AeronArchiveRecordingSubscriptionDescriptorPoller

Returns a copy 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.