Struct Client 

pub struct Client<S> { /* private fields */ }

Available on crate features icap and std only.

Wraps an inner connector and produces ICAP client connections.

The inner stack establishes the transport and can include proxy, TLS, or mTLS layers. Input and connection extensions are preserved.

Pooling contract

Pool raw transports inside Client. Do not wrap Client in a transport pool: its ICAP connection remains leased until response framing completes.

Do not leave drop_connection_if_no_response enabled on the inner pool. ICAP reports unusable transports through Rama’s shared health watcher.

Implementations

impl<S> Client<S>

pub const fn new(inner: S) -> Client<S>

Create an ICAP connector over inner.

pub const fn with_options(self, options: ConnectionOptions) -> Client<S>

Set the options used by each established ICAP connection.

pub fn set_options(&mut self, options: ConnectionOptions) -> &mut Client<S>

Set the options used by each established ICAP connection.

pub const fn options(&self) -> &ConnectionOptions

Return the options used by new ICAP connections.

pub fn get_ref(&self) -> &S

Gets a reference to the underlying service.

pub fn into_inner(self) -> S

Consumes self, returning the underlying service.

pub async fn connect<Input>( &self, input: Input, ) -> Result<EstablishedClientConnection<ClientConnection<<S as ConnectorService<Input>>::Connection>, Input>, ConnectionError>

where S: ConnectorService<Input>, <S as ConnectorService<Input>>::Connection: Io + Unpin + ExtensionsRef,

Establish an ICAP connection with the inner connector stack.

Trait Implementations

impl<S> Clone for Client<S>

where S: Clone,

fn clone(&self) -> Client<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S> Debug for Client<S>

where S: Debug,

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

Formats the value using the given formatter.

impl<S, Input> Service<Input> for Client<S>

where S: ConnectorService<Input>, <S as ConnectorService<Input>>::Connection: Io + Unpin + ExtensionsRef, Input: Send + 'static,

type Output = EstablishedClientConnection<ClientConnection<<S as ConnectorService<Input>>::Connection>, Input>

The type of the output returned by the service.

type Error = ConnectionError

The type of error returned by the service.

async fn serve( &self, input: Input, ) -> Result<<Client<S> as Service<Input>>::Output, <Client<S> as Service<Input>>::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.