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()