Struct ReaderBuilder 

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

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

Implementations

impl<'d, 'p, 't, 'q, T> ReaderBuilder<'d, 'p, 't, 'q, T>

where T: Topicable,

pub const fn new(topic: &'t Topic<'d, 'p, T>) -> Self

Creates a new ReaderBuilder for the given Topic.

Examples

use cyclonedds::builder::ReaderBuilder;
use cyclonedds::{Domain, Participant, Topic};

let domain = Domain::default();
let participant = Participant::new(&domain)?;
let topic = Topic::new(&participant, "MyTopic")?;
let reader_builder = ReaderBuilder::<Data>::new(&topic);

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

Sets the QoS for this reader builder.

Examples

use cyclonedds::builder::ReaderBuilder;
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 reader_builder = ReaderBuilder::<Data>::new(&topic).with_qos(&qos);

pub const fn with_subscriber(self, subscriber: &'p Subscriber<'d, 'p>) -> Self

Sets the Subscriber on this reader builder.

Examples

use cyclonedds::ReaderListener;
use cyclonedds::Subscriber;
use cyclonedds::builder::ReaderBuilder;

let subscriber = Subscriber::new(&participant)?;

let reader_builder = ReaderBuilder::<Data>::new(&topic).with_subscriber(&subscriber);

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

where L: AsRef<ReaderListener<T>>,

Sets the Listener on this reader builder.

Examples

use cyclonedds::ReaderListener;
use cyclonedds::builder::ReaderBuilder;

let reader_builder = ReaderBuilder::<Data>::new(&topic).with_listener(ReaderListener::new());

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

Builds the Reader.

Errors

Returns an Error if the reader failed to create.

Examples

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

let qos = QoS::new().with_durability(policy::Durability::TransientLocal);
let reader = ReaderBuilder::<Data>::new(&topic).with_qos(&qos).build()?;

Trait Implementations

impl<'domain, 'participant, 'topic, 'qos, T> Debug for ReaderBuilder<'domain, 'participant, 'topic, 'qos, T>

where T: Topicable + Debug,

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

Formats the value using the given formatter.