Trait ClientProto

pub trait ClientProto<T: 'static>: 'static {
    type Request: 'static;
    type RequestBody: 'static;
    type Response: 'static;
    type ResponseBody: 'static;
    type Error: From<Error> + 'static;
    type Transport: Transport<Self::ResponseBody, Item = Frame<Self::Response, Self::ResponseBody, Self::Error>, SinkItem = Frame<Self::Request, Self::RequestBody, Self::Error>>;
    type BindTransport: IntoFuture<Item = Self::Transport, Error = Error>;

    // Required method
    fn bind_transport(&self, io: T) -> Self::BindTransport;
}

A streaming, multiplexed client protocol.

The T parameter is used for the I/O object used to communicate, which is supplied in bind_transport.

For simple protocols, the Self type is often a unit struct. In more advanced cases, Self may contain configuration information that is used for setting up the transport in bind_transport.

Required Associated Types

type Request: 'static

Request headers.

type RequestBody: 'static

Request body chunks.

type Response: 'static

Response headers.

type ResponseBody: 'static

Response body chunks.

type Error: From<Error> + 'static

Errors, which are used both for error frames and for the service itself.

type Transport: Transport<Self::ResponseBody, Item = Frame<Self::Response, Self::ResponseBody, Self::Error>, SinkItem = Frame<Self::Request, Self::RequestBody, Self::Error>>

The frame transport, which usually take T as a parameter.

type BindTransport: IntoFuture<Item = Self::Transport, Error = Error>

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

In simple cases, Result<Self::Transport, Self::Error> often suffices.

Required Methods

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

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

Implementors