[−][src]Crate bmrng

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;

error	The errors produced by this crate
unbounded	The unbounded channel alternative

RequestReceiver	Receive requests values from the associated `RequestSender`
RequestReceiverStream	A wrapper around [`bmrng::RequestReceiver`] that implements [`Stream`].
RequestSender	Send values to the associated `RequestReceiver`.
Responder	Send values back to the `RequestSender` or `RequestReceiver`
ResponseReceiver	Receive responses from a `Responder`

channel	Creates a bounded mpsc request-response channel for communicating between asynchronous tasks with backpressure
channel_with_timeout	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