Struct ServerTransaction 

pub struct ServerTransaction<'a, IO> { /* private fields */ }

Available on crate features icap and std only.

One inbound ICAP request and its response transaction.

Implementations

impl<'a, IO> ServerTransaction<'a, IO>

where IO: Io + Unpin,

pub const fn request(&self) -> &Request

Return the request metadata and encapsulated HTTP heads.

pub async fn next_data(&mut self) -> Result<Option<Bytes>, Error>

Read the next zero-copy request-body data segment.

A returned segment may be smaller than the peer’s wire chunk. When a Preview ends without ieof, this returns None and body_end returns BodyEnd::Preview.

pub const fn body_end(&self) -> Option<BodyEnd>

Return the terminal state after next_data returns None.

pub fn trailers(&self) -> Option<&TrailerBlock>

Return trailers from the most recently completed body segment.

pub async fn continue_preview( &mut self, response: Response, ) -> Result<(), Error>

Send a tagged 100 Continue response and read the post-Preview body.

pub async fn respond( self, response: Response, ) -> Result<ServerResponse<'a, IO>, Error>

Start the final response after reaching a request-body boundary.

pub async fn respond_early( self, response: Response, ) -> Result<ServerResponse<'a, IO>, Error>

Send a final response before the request body reaches a boundary.

The response writer discards the remaining request concurrently with response writes so a keep-alive connection can remain synchronized. Read any request data an adaptation needs before responding. A closing request or response instead uses the transport-close fallback permitted by the ICAP errata.

pub async fn respond_streaming( self, response: Response, ) -> Result<ServerResponse<'a, IO>, Error>

Start a final response while retaining the unread request body.

Unlike respond_early, response writes do not discard request data to make progress. Use ServerResponse::next_request_data between response writes to stream an adapted body without buffering the complete request. The peer must monitor for an early ICAP response while it transmits its request body, as required by the ICAP errata.

Trait Implementations

impl<IO> ExtensionsRef for ServerTransaction<'_, IO>

fn extensions(&self) -> &Extensions

Get reference to the underlying Extensions store