Module bmrng::unbounded[][src]

The unbounded channel alternative

Structs

UnboundedRequestReceiver

Receive requests values from the associated UnboundedRequestSender

UnboundedRequestReceiverStream

A wrapper around UnboundedRequestReceiver that implements [Stream].

UnboundedRequestSender

Send values to the associated UnboundedRequestReceiver.

UnboundedResponder

Send values back to the UnboundedRequestSender or UnboundedRequestReceiver

Functions

channel

Creates an unbounded mpsc request-response channel for communicating between asynchronous tasks without backpressure.

channel_with_timeout

Creates an unbounded mpsc request-response channel for communicating between asynchronous tasks without 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