Struct framecodecs::remote_addr::RemoteAddrProto

pub struct RemoteAddrProto<C, Kind> { /* fields omitted */ }

A wrapper protocol provides remote address of connection. This protocol implements only ServerProto.

Methods

impl<C: Clone, Kind> RemoteAddrProto<C, Kind>

fn new(inner: C) -> Self

Trait Implementations

impl<C: Debug, Kind: Debug> Debug for RemoteAddrProto<C, Kind>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<C: Clone, Kind: Clone> Clone for RemoteAddrProto<C, Kind>

fn clone(&self) -> RemoteAddrProto<C, Kind>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<C: Copy, Kind: Copy> Copy for RemoteAddrProto<C, Kind>

impl<C> ServerProto<TcpStream> for RemoteAddrProto<C, Pipeline> where C: Codec + Clone + 'static

type Request = (SocketAddr, C::In)

Request messages.

type Response = C::Out

Response messages.

type Error = Error

Errors produced by the service.

type Transport = Framed<TcpStream, RemoteAddrCodec<C, Pipeline>>

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

type BindTransport = Result<Self::Transport>

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

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

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

impl<C, In, Out> ServerProto<TcpStream> for RemoteAddrProto<C, Multiplex> where C: Codec<In=(RequestId, In), Out=(RequestId, Out)> + Clone + 'static,
        In: 'static,
        Out: 'static

type Request = (SocketAddr, In)

Request messages.

type Response = Out

Response messages.

type Error = Error

Errors produced by the service.

type Transport = Framed<TcpStream, RemoteAddrCodec<C, Multiplex>>

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

type BindTransport = Result<Self::Transport>

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

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

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