Struct Server 

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

Available on crate features icap and std only.

ICAP server backed by an ordinary Rama request service.

Server owns connection reuse, close handling, Preview decisions, and the bounded driver between the wire transaction and IncomingRequest. The inner service receives a lifetime-independent request with a backpressured streaming body and returns an OutgoingResponse. It can therefore use the normal Rama service layers. An outgoing body may retain the incoming body and transform it incrementally; the connection driver continues serving body reads while it writes response frames.

Server itself implements Service for Rama streams with ExtensionsRef, so it can be passed directly to listeners such as rama_tcp::server::TcpListener::serve.

Implementations

impl<S> Server<S>

pub fn new( inner: S, service_tag: impl AsRef<[u8]>, ) -> Result<Server<S>, BuildError>

Create an ICAP server wrapping inner.

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

Set the options used by each accepted ICAP connection.

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

Set the options used by each accepted ICAP connection.

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

Return the options used by accepted ICAP connections.

pub fn service_tag(&self) -> &[u8]

Return the quoted ICAP service tag used for interim responses.

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 fn serve_connection<IO>( &self, io: IO, ) -> impl Future<Output = Result<(), ServerError>> + Send

where IO: Io + Unpin + ExtensionsRef, S: Service<IncomingRequest, Output = OutgoingResponse>, <S as Service<IncomingRequest>>::Error: Into<Box<dyn Error + Send + Sync>>,

Serve one established stream.

Trait Implementations

impl<S> Clone for Server<S>

where S: Clone,

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S> Debug for Server<S>

where S: Debug,

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

Formats the value using the given formatter.

impl<S, IO> Service<IO> for Server<S>

where IO: Io + Unpin + ExtensionsRef, S: Service<IncomingRequest, Output = OutgoingResponse>, <S as Service<IncomingRequest>>::Error: Into<Box<dyn Error + Send + Sync>>,

type Output = ()

The type of the output returned by the service.

type Error = ServerError

The type of error returned by the service.

fn serve( &self, io: IO, ) -> impl Future<Output = Result<<Server<S> as Service<IO>>::Output, <Server<S> as Service<IO>>::Error>> + Send

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.