Struct TopicBuilder 

pub struct TopicBuilder<'domain, 'participant, 'qos, 'name, T>
where
    T: Topicable,
{ /* private fields */ }

Builder for Topic<T> (accessible via Topic::builder).

Implementations

impl<'d, 'p, 'q, 'n, T> TopicBuilder<'d, 'p, 'q, 'n, T>

where T: Topicable,

pub const fn new(participant: &'p Participant<'d>, topic_name: &'n str) -> Self

Creates a new TopicBuilder for the given Participant.

Examples

use cyclonedds::builder::TopicBuilder;
use cyclonedds::{Domain, Participant};

let domain = Domain::default();
let participant = Participant::new(&domain)?;
let topic_builder = TopicBuilder::<Data>::new(&participant, "MyTopic");

pub const fn with_qos(self, qos: &'q QoS) -> Self

Sets the QoS for this topic builder.

Examples

use cyclonedds::builder::TopicBuilder;
use cyclonedds::qos::policy;
use cyclonedds::{Duration, QoS};

let qos = QoS::new().with_reliability(policy::Reliability::Reliable {
    max_blocking_time: Duration::from_millis(100),
});
let topic_builder = TopicBuilder::<Data>::new(&participant, "MyTopic").with_qos(&qos);

pub fn with_listener<L>(self, listener: L) -> Self

where L: AsRef<TopicListener<T>>,

Sets the Listener on this topic builder.

Examples

use cyclonedds::TopicListener;
use cyclonedds::builder::TopicBuilder;

let participant_builder =
    TopicBuilder::<Data>::new(&participant, "MyTopic").with_listener(TopicListener::new());

pub fn build(self) -> Result<Topic<'d, 'p, T>>

Builds the Topic.

Errors

Returns an Error if the topic failed to create.

Examples

use cyclonedds::QoS;
use cyclonedds::builder::TopicBuilder;
use cyclonedds::qos::policy;

let qos = QoS::new().with_durability(policy::Durability::TransientLocal);
let topic = TopicBuilder::<Data>::new(&participant, "MyTopic")
    .with_qos(&qos)
    .build()?;

Trait Implementations

impl<'domain, 'participant, 'qos, 'name, T> Debug for TopicBuilder<'domain, 'participant, 'qos, 'name, T>

where T: Topicable + Debug,

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

Formats the value using the given formatter.