Function channel

pub fn channel<Req: RpcMessage, Res: RpcMessage>(
    buffer: usize,
) -> (FlumeListener<Req, Res>, FlumeConnector<Res, Req>)

Create a flume listener and a connected flume connector.

buffer the size of the buffer for each channel. Keep this at a low value to get backpressure