Struct SinkRefHandle 

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

Consumer-side advertisement of a Sink<T>. The producer attaches a source via SinkRefHandle::attach which then pumps into the receiver-owned stream.

Fields

id: u64

Implementations

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

pub fn new(buffer: usize) -> Self

pub fn attach(&self, source: Source<T>)

Producer-side: attach source so its elements drain into the sink. Multiple attaches are merged.

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

Consumer-side: take the source that drains every attached producer.