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<()> where
R: Rpc,
S: RpcServerStub<R, I, O>,
I: RpcFrame<R::Request>,
O: RpcFrame<R::Response>,
T: Stream<Item = Result<I>> + Unpin,
U: Sink<O, Error = Error> + Unpin,