Struct SourceRefHandle 

pub struct SourceRefHandle<T: Send + 'static> {
    pub id: u64,
    /* private fields */
}

Producer-side advertisement of a Source<T>. The owner pumps elements; consumers subscribe via SourceRefHandle::take_source.

Fields

id: u64

Globally-unique stream ref id (unique per node).

Implementations

impl<T: Send + 'static> SourceRefHandle<T>

pub fn advertise(source: Source<T>, buffer: usize) -> Self

Advertise source as a stream ref. Returns the handle the caller serializes/sends to the consumer side.

pub fn take_source(&self) -> Source<T>

Take the consumer source. Calling more than once yields Source::empty() (the receiver only exists once).