Struct BuiltinSubscriber 

pub struct BuiltinSubscriber { /* private fields */ }

Builtin-Subscriber. Haelt 4 vor-erzeugte DataReader fuer die Builtin-Topics. Die inbox jedes Readers ist als Arc<Mutex<Vec<crate::runtime::UserSample>>> herausgegeben, damit der Runtime- Discovery-Hook neue Samples ohne Lock-Cycles einspeisen kann.

Implementations

impl BuiltinSubscriber

pub fn new() -> Self

Konstruiert einen Builtin-Subscriber mit vor-erzeugten Readern fuer alle 4 Builtin-Topics. Wird genau einmal pro DomainParticipant (vom Konstruktor) gerufen.

pub fn subscriber(&self) -> &Subscriber

Underlying Subscriber-Handle (API-Spiegel zu User-Subscribers).

pub fn sinks(&self) -> BuiltinSinks

Sinks fuer den Runtime-Discovery-Hook. Sollte nur intern (im DcpsRuntime) genutzt werden.

pub fn lookup_datareader<T: BuiltinTopic>( &self, topic_name: &str, ) -> Result<DataReader<T>>

Liefert eine Kopie des typed DataReaders fuer ein Builtin-Topic. Spec: Subscriber::lookup_datareader(topic_name) (DDS 1.4 §2.2.2.5.1.5).

Topic-Name + Type-Parameter MUESSEN konsistent sein (z.B. lookup_datareader::<ParticipantBuiltinTopicData>("DCPSParticipant")), sonst gibt es BadParameter.

Errors

BadParameter wenn topic_name keinem Builtin-Topic entspricht oder Type-Parameter und Topic-Name auseinanderlaufen.

pub fn participant_reader(&self) -> DataReader<ParticipantBuiltinTopicData>

Direkter Zugriff auf den DCPSParticipant-Reader (Convenience- API, vermeidet generische Lookup-Pfade fuer Builtin-Topics).

pub fn topic_reader(&self) -> DataReader<TopicBuiltinTopicData>

Direkter Zugriff auf den DCPSTopic-Reader.

pub fn publication_reader(&self) -> DataReader<PublicationBuiltinTopicData>

Direkter Zugriff auf den DCPSPublication-Reader.

pub fn subscription_reader(&self) -> DataReader<SubscriptionBuiltinTopicData>

Direkter Zugriff auf den DCPSSubscription-Reader.

Trait Implementations

impl Debug for BuiltinSubscriber

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

Formats the value using the given formatter.

impl Default for BuiltinSubscriber

fn default() -> Self

Returns the “default value” for a type.