Struct actix_net::connector::Connector

pub struct Connector<T = String> { /* fields omitted */ }

Methods

impl<T: HostAware> Connector<T>

pub fn new(cfg: ResolverConfig, opts: ResolverOpts) -> Self

pub fn with_resolver(     resolver: Resolver<T> ) -> impl Service<Request = T, Response = (T, ConnectionInfo, TcpStream), Error = ConnectorError> + Clone

pub fn new_service<E>( ) -> impl NewService<Request = T, Response = (T, ConnectionInfo, TcpStream), Error = ConnectorError, InitError = E> + Clone

pub fn new_service_with_config<E>(     cfg: ResolverConfig,     opts: ResolverOpts ) -> impl NewService<Request = T, Response = (T, ConnectionInfo, TcpStream), Error = ConnectorError, InitError = E> + Clone

pub fn change_request<T2: HostAware>(&self) -> Connector<T2>

Trait Implementations

impl<T: HostAware> Default for Connector<T>

fn default() -> Self

Returns the "default value" for a type.

impl<T> Clone for Connector<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: HostAware> Service for Connector<T>

type Request = T

Requests handled by the service.

type Response = (T, ConnectionInfo, TcpStream)

Responses given by the service.

type Error = ConnectorError

Errors produced by the service.

type Future = ConnectorFuture<T>

The future response value.

fn poll_ready(&mut self) -> Poll<(), Self::Error>

Returns Ready when the service is able to process requests.

fn call(&mut self, req: Self::Request) -> Self::Future

Process the request and return the response asynchronously.

fn ready(self) -> Ready<Self>

A future yielding the service when it is ready to accept a request.