Expand description
Memory transport implementation using flume
Structs§
- Future returned by [FlumeServerEndpoint::accept_bi]
- A flume based connection to a server endpoint.
- A flume based server endpoint.
- Future returned by FlumeConnection::open
- Stream for memory channels
- Sink for memory channels
Enums§
- AcceptBiError for mem channels.
- CreateChannelError for mem channels.
- OpenBiError for mem channels.
- Error when receiving from a channel
- SendError for mem channels.
Functions§
- Create a flume server endpoint and a connected flume client channel.