Function bmrng::unbounded::channel_with_timeout [−][src]
pub fn channel_with_timeout<Req, Res>(
timeout_duration: Duration
) -> (UnboundedRequestSender<Req, Res>, UnboundedRequestReceiver<Req, Res>)
Expand description
Creates an unbounded mpsc request-response channel for communicating between asynchronous tasks without backpressure and a request timeout
Also see bmrng::channel()