Function tiny_rpc::rpc::serve [−][src]
pub async fn serve<R, S, I, O, T, U>(
stub: impl Into<Arc<S>>,
recv: T,
send: U
) -> Result<(), Error> where
R: Rpc,
S: RpcServerStub<R, I, O>,
I: RpcFrame,
O: RpcFrame,
T: Stream<Item = I> + Unpin,
U: Sink<O, Error = Error> + Unpin,