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,