Struct PullBuilder

pub struct PullBuilder<St, K, F, Q = K>
where
    St: ?Sized + Stream,
{ /* private fields */ }

The builder forwards each stream item according to its key to a destination receiver.

Implementations

impl<St, K, Q, F> PullBuilder<St, K, F, Q>

where St: 'static + Send + Stream, St::Item: 'static + Send, F: 'static + Send + FnMut(&St::Item) -> Q, K: 'static + Send + Hash + Eq + Borrow<Q>, Q: Send + Hash + Eq,

pub fn new<B>(stream: St, buf_size: B, key_fn: F) -> Self

where B: Into<BufSize>,

Creates the builder.

The buf_size sets the channel size for each registered receiver. The key_fn is used to compute the key for each input item.

pub fn register(&mut self, key: K) -> Option<RecvStream<'static, St::Item>>

Creates a receiver binding to the key.

If the key is already registered, it returns None.

pub fn build(self) -> RecvStream<'static, St::Item>

Finish the builder and start forwarding items to receivers.

It returns a special leaking receiver that accepts items which key is not registered or the destination receiver is closed.