Enum muxrpc::IncomingRpc

pub enum IncomingRpc<R: AsyncRead, W: AsyncWrite> {
    Source(RpcSink<W>),
    Sink(RpcStream<R, Value, Value>),
    Duplex(RpcSink<W>, RpcStream<R, Value, Value>),
    Async(PeerAsync<W>),
    Sync(PeerSync<W>),
}

An incoming packet, initiated by the peer.

Variants

Source(RpcSink<W>)

A source request. You get a sink, the peer got a stream.

Sink(RpcStream<R, Value, Value>)

A sink request. You get a stream, the peer got a sink.

Duplex(RpcSink<W>, RpcStream<R, Value, Value>)

A duplex request. Both peers get a stream and a sink.

Async(PeerAsync<W>)

An async request. You get an PeerAsync, the peer got an AsyncResponse.

Sync(PeerSync<W>)

A sync request. You get an PeerSync, the peer got an AsyncResponse.

Trait Implementations