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;
Modules
Structs
Receive requests values from the associated RequestSender
A wrapper around RequestReceiver
that implements Stream
.
Send values to the associated RequestReceiver
.
Send values back to the RequestSender
or RequestReceiver
Receive responses from a Responder
Functions
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
Type Definitions
The internal data sent in the MPSC request channel, a tuple that contains the request and the oneshot response channel responder