Struct BuiltinSinks 

pub struct BuiltinSinks {
    pub participant: Arc<Mutex<Vec<UserSample>>>,
    pub topic: Arc<Mutex<Vec<UserSample>>>,
    pub publication: Arc<Mutex<Vec<UserSample>>>,
    pub subscription: Arc<Mutex<Vec<UserSample>>>,
}

Bundle der 4 shared inboxes — wird vom DcpsRuntime an den SPDP/SEDP-Hot-Path weitergereicht. Cloning ist billig (Arc-Bumps).

Fields

participant: Arc<Mutex<Vec<UserSample>>>

Inbox des DCPSParticipant-Readers.

topic: Arc<Mutex<Vec<UserSample>>>

Inbox des DCPSTopic-Readers.

publication: Arc<Mutex<Vec<UserSample>>>

Inbox des DCPSPublication-Readers.

subscription: Arc<Mutex<Vec<UserSample>>>

Inbox des DCPSSubscription-Readers.

Implementations

impl BuiltinSinks

pub fn push_participant( &self, sample: &ParticipantBuiltinTopicData, ) -> Result<()>

Bequemer Helfer: encoded ein Builtin-Sample und schiebt es in den passenden Reader-Inbox.

Errors

WireError wenn das Encoding fehlschlaegt; PreconditionNotMet wenn der Mutex vergiftet ist.

pub fn push_topic(&self, sample: &TopicBuiltinTopicData) -> Result<()>

Push fuer DCPSTopic.

Errors

Wie Self::push_participant.

pub fn push_publication( &self, sample: &PublicationBuiltinTopicData, ) -> Result<()>

Push fuer DCPSPublication.

Errors

Wie Self::push_participant.

pub fn push_subscription( &self, sample: &SubscriptionBuiltinTopicData, ) -> Result<()>

Push fuer DCPSSubscription.

Errors

Wie Self::push_participant.

Trait Implementations

impl Clone for BuiltinSinks

fn clone(&self) -> BuiltinSinks

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BuiltinSinks

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

Formats the value using the given formatter.