Function ort_tcp::muxer::spawn_client[][src]

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