[][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;

Modules

error

The errors produced by this crate

unbounded

The unbounded channel alternative

Structs

RequestReceiver

Receive requests values from the associated RequestSender

RequestSender

Send values to the associated RequestReceiver.

Responder

Send values back to the RequestSender or RequestReceiver

ResponseReceiver

Receive responses from a Responder

Functions

channel

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

Type Definitions

Payload

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