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