Struct OriginProducer

pub struct OriginProducer { /* private fields */ }

Announces broadcasts to consumers over the network.

Implementations

impl OriginProducer

pub fn new() -> Self

pub fn publish<S: ToString>( &mut self, path: S, broadcast: BroadcastConsumer, ) -> bool

Announce a broadcast, returning true if it was unique.

pub fn publish_all(&mut self, broadcasts: OriginConsumer)

Publish all broadcasts from the given origin.

pub fn publish_prefix(&mut self, prefix: &str, broadcasts: OriginConsumer)

Publish all broadcasts from the given origin with an optional prefix.

pub fn consume(&self, path: &str) -> Option<BroadcastConsumer>

Get a specific broadcast by name.

pub fn consume_all(&self) -> OriginConsumer

Subscribe to all announced broadcasts.

pub fn consume_prefix<S: ToString>(&self, prefix: S) -> OriginConsumer

Subscribe to all announced broadcasts matching the prefix.

pub async fn unused(&self)

Wait until all consumers have been dropped.

NOTE: subscribe can be called to unclose the producer.

Trait Implementations

impl Clone for OriginProducer

fn clone(&self) -> OriginProducer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for OriginProducer

fn default() -> OriginProducer

Returns the “default value” for a type.