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