Struct TcpConnectRequest 

pub struct TcpConnectRequest {
    pub ctx: CallContext,
    pub addr: SocketAddr,
    pub timeout: Option<Duration>,
}

Fields

ctx: CallContext

addr: SocketAddr

timeout: Option<Duration>

Implementations

impl TcpConnectRequest

pub fn new( ctx: CallContext, addr: SocketAddr, timeout: Option<Duration>, ) -> Self

Trait Implementations

impl Clone for TcpConnectRequest

fn clone(&self) -> TcpConnectRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TcpConnectRequest

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<C> Service<TcpConnectRequest> for TcpConnectorService<C>

where C: TcpConnector,

type Response = Box<dyn ConnectionIo>

Responses given by the service.

type Error = WireError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<TcpConnectorService<C> as Service<TcpConnectRequest>>::Response, <TcpConnectorService<C> as Service<TcpConnectRequest>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, request: TcpConnectRequest) -> Self::Future

Process the request and return the response asynchronously.