Struct TypeFollower 

pub struct TypeFollower { /* private fields */ }

Tracks which (topic, type_name) publications a monitoring tool has already attached to, so it can attach a type-following raw reader to each newly discovered writer type (including late joiners) exactly once.

The dedup core (TypeFollower::newly_seen) is pure — feed it the discovered pairs and it returns only the ones not seen before — so it is unit-testable without a live runtime. TypeFollower::poll is the convenience that reads DcpsRuntime::discovered_publication_topics().

Implementations

impl TypeFollower

pub fn new<I, S>(topics: I) -> Self

where I: IntoIterator<Item = S>, S: Into<String>,

Follow only the given topics. An empty iterator follows all topics.

pub fn wants_topic(&self, topic: &str) -> bool

True if this follower accepts samples for topic.

pub fn newly_seen<I, A, B>(&mut self, discovered: I) -> Vec<(String, String)>

where I: IntoIterator<Item = (A, B)>, A: Into<String>, B: Into<String>,

Pure dedup core: given the currently discovered (topic, type_name) pairs, return those matching the topic filter that have not been seen before, marking them seen. Order-preserving; duplicates within the input collapse to one.

pub fn poll(&mut self, runtime: &DcpsRuntime) -> Vec<(String, String)>

Poll a runtime’s discovered publications and return the newly-appeared (topic, type_name) pairs to attach a follower reader to.

Trait Implementations

impl Debug for TypeFollower

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

Formats the value using the given formatter.

impl Default for TypeFollower

fn default() -> TypeFollower

Returns the “default value” for a type.