Struct OriginConsumer

pub struct OriginConsumer { /* private fields */ }

Consumes announced broadcasts matching against an optional prefix.

Implementations

impl OriginConsumer

pub async fn next(&mut self) -> Option<OriginUpdate>

Returns the next (un)announced broadcast and the absolute path.

The broadcast will only be None if it was previously Some. The same path won’t be announced/unannounced twice, instead it will toggle.

Note: The returned path is absolute and will always match this consumer’s prefix.

pub fn consume<'a>( &self, suffix: impl Into<PathRef<'a>>, ) -> Option<BroadcastConsumer>

Get a specific broadcast by path.

This is relative to the consumer’s prefix. Returns None if the path hasn’t been announced yet.

pub fn consume_all(&self) -> OriginConsumer

pub fn consume_prefix<'a>( &self, prefix: impl Into<PathRef<'a>>, ) -> OriginConsumer

pub fn prefix(&self) -> &Path

Trait Implementations

impl Clone for OriginConsumer

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.