Function connection

pub fn connection<Req: RpcMessage, Res: RpcMessage>(
    buffer: usize,
) -> (FlumeServerEndpoint<Req, Res>, FlumeConnection<Res, Req>)

Create a flume server endpoint and a connected flume client channel.

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