Struct rmp_rpc::Protocol

pub struct Protocol;

The MessagePack-RPC transport protocol. See the tokio_proto documentation

Examples

use tokio_proto::TcpServer;
fn main() {
    let addr = "127.0.0.1:54321".parse().unwrap();
    let tcp_server = TcpServer::new(Protocol, addr);
    // ...
}

Trait Implementations

impl<T: AsyncRead + AsyncWrite + 'static> ServerProto<T> for Protocol

type Request = Message

Request messages.

type Response = Message

Response messages.

type Transport = Framed<T, Codec>

The message transport, which works with I/O objects of type T.

type BindTransport = Result<Self::Transport, Error>

A future for initializing a transport from an I/O object.

fn bind_transport(&self, io: T) -> Self::BindTransport

Build a transport from the given I/O object, using self for any configuration.