Struct cb_fut::CBStreamBlocked

pub struct CBStreamBlocked<R, T> where
    R: 'static + Clone,  { /* fields omitted */ }

An object that represent callback function arguments. It implement futures::Stream trait and return value to the function by using CBBlockResult.

It can be obtain by using macro stream_blocked. See stream_blocked for example usage.

This struct shall be semi-transparent to user.

Implementations

impl<R, T> CBStreamBlocked<R, T> where
    R: 'static + Clone, 

pub fn new(
    return_sender: Sender<R>,
    reciever: UnboundedReceiver<T>,
    default_ret_val: R
) -> CBStreamBlocked<R, T> where
    R: 'static + Clone, 

You will likely use this macro stream_blocked instead of trying to construct this struct using this method.

It require channel to communicate back and forth between the function and this struct.