Trait tokio_proto::BindClient

[+] Show declaration

pub trait BindClient<Kind, T: 'static>: 'static {
    type ServiceRequest;
    type ServiceResponse;
    type ServiceError;
    type BindClient: Service<Request = Self::ServiceRequest, Response = Self::ServiceResponse, Error = Self::ServiceError>;
    fn bind_client(&self, handle: &Handle, io: T) -> Self::BindClient;
}

[−] Expand description

Binds an I/O object as a client of a service.

This trait is not intended to be implemented directly; instead, implement one of the server protocol traits:

• pipeline::ClientProto
• multiplex::ClientProto
• streaming::pipeline::ClientProto
• streaming::multiplex::ClientProto

See the crate documentation for more details on those traits.

The Kind parameter, in particular, is a zero-sized type used to allow blanket implementation from the various protocol traits. Any additional implementations of this trait should use their own zero-sized kind type to distinguish them.

Associated Types

type ServiceRequest[−]

The request type for the service.

type ServiceResponse[−]

The response type for the service.

type ServiceError[−]

The error type for the service.

type BindClient: Service<Request = Self::ServiceRequest, Response = Self::ServiceResponse, Error = Self::ServiceError>[−]

The bound service.

Required methods

fn bind_client(&self, handle: &Handle, io: T) -> Self::BindClient[−]

Bind an I/O object as a service.

Implementors

impl<P, T, B> BindClient<StreamingMultiplex<B>, T> for P where
    P: ClientProto<T>,
    T: 'static,
    B: Stream<Item = P::RequestBody, Error = P::Error> + 'static, [−]

[+] Show hidden undocumented items

type ServiceRequest = Message<P::Request, B>

type ServiceResponse = Message<P::Response, Body<P::ResponseBody, P::Error>>

type ServiceError = P::Error

type BindClient = ClientProxy<Self::ServiceRequest, Self::ServiceResponse, Self::ServiceError>

fn bind_client(&self, handle: &Handle, io: T) -> Self::BindClient

impl<P, T, B> BindClient<StreamingPipeline<B>, T> for P where
    P: ClientProto<T>,
    T: 'static,
    B: Stream<Item = P::RequestBody, Error = P::Error> + 'static, [−]

[+] Show hidden undocumented items

type ServiceRequest = Message<P::Request, B>

type ServiceResponse = Message<P::Response, Body<P::ResponseBody, P::Error>>

type ServiceError = P::Error

type BindClient = ClientProxy<Self::ServiceRequest, Self::ServiceResponse, Self::ServiceError>

fn bind_client(&self, handle: &Handle, io: T) -> Self::BindClient

impl<T: 'static, P: ClientProto<T>> BindClient<Multiplex, T> for P[−]

[+] Show hidden undocumented items

type ServiceRequest = P::Request

type ServiceResponse = P::Response

type ServiceError = Error

type BindClient = ClientService<T, P>

fn bind_client(&self, handle: &Handle, io: T) -> Self::BindClient

impl<T: 'static, P: ClientProto<T>> BindClient<Pipeline, T> for P[−]

[+] Show hidden undocumented items

type ServiceRequest = P::Request

type ServiceResponse = P::Response

type ServiceError = Error

type BindClient = ClientService<T, P>

fn bind_client(&self, handle: &Handle, io: T) -> Self::BindClient