Struct hyper_srv::ServiceConnector

pub struct ServiceConnector<C> { /* fields omitted */ }

A wrapper around Hyper’s Connector with ability to preresolve SRV DNS records before supplying resulting host:port pair to the underlying connector.

Implementations

impl<C> ServiceConnector<C>

pub fn new(inner: C, resolver: Option<TokioAsyncResolver>) -> Self

Creates a new instance of ServiceConnector with provided connector and optional DNS resolver. If the resolver is set to None all connections will be handled directly by the underlying connector. This allows to toggle SRV resolving mechanism without changing a type of connector used in a client (as it must be named and can not even be made into a trait object).

Trait Implementations

impl<C: Clone> Clone for ServiceConnector<C>

fn clone(&self) -> ServiceConnector<C>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for ServiceConnector<C>

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

Formats the value using the given formatter.

impl<C> Service<Uri> for ServiceConnector<C> where
    C: Service<Uri> + Clone + Unpin,
    C::Response: AsyncRead + AsyncWrite + Connection + Unpin + Send + 'static,
    C::Error: Into<Box<dyn Error + Send + Sync>>,
    C::Future: Unpin + Send, 

type Response = C::Response

Responses given by the service.

type Error = ServiceError

Errors produced by the service.

type Future = ServiceConnecting<C>

The future response value.

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

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

fn call(&mut self, uri: Uri) -> Self::Future

Process the request and return the response asynchronously.