Struct par_stream::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.