Function brw::spawn[][src]

pub fn spawn<B, R, W, BI, WI>(
    broker: B,
    reader: R,
    writer: W
) -> (JoinHandle<Result<(), B::Error>>, Sender<BI>) where
    B: Broker<Item = BI, WriterItem = WI> + Send + 'static,
    R: Reader<BrokerItem = BI> + Send + 'static,
    W: Writer<Item = WI> + Send + 'static,
    BI: Send + 'static,
    WI: Send + 'static, 
Expand description

Spawning a broker-reader-writer with tokio runtime