Function ort_tcp::muxer::spawn_server

pub fn spawn_server<Req, Rsp, R, W>(
    read: R, 
    write: W, 
    drain: Drain, 
    buffer_capacity: usize
) -> (Receiver<(Req, Sender<Rsp>)>, JoinHandle<Result<()>>) where
    Req: Send + 'static,
    Rsp: Send + 'static,
    R: Stream<Item = Result<Frame<Req>>> + Send + Unpin + 'static,
    W: Sink<Frame<Rsp>, Error = Error> + Send + Unpin + 'static,