Crate bmrng[−][src]

Expand description

An async MPSC request-response channel for Tokio, where you can send a response to the sender.

See bmrng::channel() for a channel with backpressure and bmrng::unbounded::channel() for a channel without backpressure.

Re-exports

pub use unbounded::channel as unbounded_channel;

pub use unbounded::channel_with_timeout as unbounded_channel_with_timeout;

The errors produced by this crate

The unbounded channel alternative

Receive requests values from the associated RequestSender

A wrapper around RequestReceiver that implements Stream.

Send values to the associated RequestReceiver.

Receive responses from a Responder

Creates a bounded mpsc request-response channel for communicating between asynchronous tasks with backpressure

Creates a bounded mpsc request-response channel for communicating between asynchronous tasks with backpressure and a request timeout

The internal data sent in the MPSC request channel, a tuple that contains the request and the oneshot response channel responder