quic_rpc::transport

Module flume

Available on crate feature flume-transport only.

Expand description

Memory transport implementation using flume

Structs§

AcceptFuture: Future returned by FlumeListener::accept
FlumeConnector: A flume based connector.
FlumeListener: A flume based listener.
OpenFuture: Future returned by FlumeConnector::open
RecvStream: Stream for memory channels
SendSink: Sink for memory channels

Enums§

AcceptError: AcceptError for mem channels.
CreateChannelError: CreateChannelError for mem channels.
OpenError: OpenError for mem channels.
RecvError: Error when receiving from a channel
SendError: SendError for mem channels.

Functions§

channel: Create a flume listener and a connected flume connector.