Struct PublisherBuilder 

pub struct PublisherBuilder<'domain, 'participant, 'qos> { /* private fields */ }

Builder for Publisher (accessible via Publisher::builder).

Implementations

impl<'d, 'p, 'q> PublisherBuilder<'d, 'p, 'q>

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

Creates a new PublisherBuilder for the given Participant.

Examples

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

let domain = Domain::default();
let participant = Participant::new(&domain)?;
let publisher_builder = PublisherBuilder::new(&participant);

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

Sets the QoS for this publisher builder.

Examples

use cyclonedds::builder::PublisherBuilder;
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 publisher_builder = PublisherBuilder::new(&participant).with_qos(&qos);

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

where L: AsRef<PublisherListener>,

Sets the Listener on this publisher builder.

Examples

use cyclonedds::Listener;
use cyclonedds::builder::PublisherBuilder;

let publisher_builder = PublisherBuilder::new(&participant).with_listener(Listener::new());

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

Builds the Publisher.

Errors

Returns an Error if the publisher failed to create.

Examples

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

let qos = QoS::new().with_durability(policy::Durability::TransientLocal);
let publisher = PublisherBuilder::new(&participant).with_qos(&qos).build()?;

Trait Implementations

impl<'domain, 'participant, 'qos> Debug for PublisherBuilder<'domain, 'participant, 'qos>

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

Formats the value using the given formatter.