[−][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; |
Modules
error | The errors produced by this crate |
unbounded | The unbounded channel alternative |
Structs
RequestReceiver | Receive requests values from the associated |
RequestSender | Send values to the associated |
Responder | Send values back to the |
ResponseReceiver | Receive responses from a |
Functions
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 |
Type Definitions
Payload | The internal data sent in the MPSC request channel, a tuple that contains the request and the oneshot response channel responder |