Function quic_rpc::transport::flume::connection

pub fn connection<S: Service>(
    buffer: usize,
) -> (FlumeServerEndpoint<S>, FlumeConnection<S>)

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