Trait BindClient

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>;

    // Required method
    fn bind_client(&self, handle: &Handle, io: T) -> Self::BindClient;
}

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.

Required 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,

type ServiceRequest = Message<<P as ClientProto<T>>::Request, B>

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

type ServiceError = <P as ClientProto<T>>::Error

type BindClient = ClientProxy<<P as BindClient<StreamingMultiplex<B>, T>>::ServiceRequest, <P as BindClient<StreamingMultiplex<B>, T>>::ServiceResponse, <P as BindClient<StreamingMultiplex<B>, T>>::ServiceError>

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,

type ServiceRequest = Message<<P as ClientProto<T>>::Request, B>

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

type ServiceError = <P as ClientProto<T>>::Error

type BindClient = ClientProxy<<P as BindClient<StreamingPipeline<B>, T>>::ServiceRequest, <P as BindClient<StreamingPipeline<B>, T>>::ServiceResponse, <P as BindClient<StreamingPipeline<B>, T>>::ServiceError>

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

type ServiceRequest = <P as ClientProto<T>>::Request

type ServiceResponse = <P as ClientProto<T>>::Response

type ServiceError = Error

type BindClient = ClientService<T, P>

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

type ServiceRequest = <P as ClientProto<T>>::Request

type ServiceResponse = <P as ClientProto<T>>::Response

type ServiceError = Error

type BindClient = ClientService<T, P>