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)

Publish a broadcast, announcing it to all consumers.

The broadcast will be unannounced when it is closed. If there is already a broadcast with the same path, then it will be replaced and reannounced. If the old broadcast is closed before the new one, then nothing will happen. If the new broadcast is closed before the old one, then the old broadcast will be reannounced.

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.

The most recent, non-closed broadcast will be returned if there are duplicates.

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 fn consume_exact<S: ToString>(&self, path: S) -> OriginConsumer

Wait for an exact broadcast to be announced.

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.

const 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.