Struct OwnedClientResponse 

pub struct OwnedClientResponse<IO> { /* private fields */ }

Available on crate features http and icap only.

An owned, typed streaming response to an HTTP adaptation request.

Unlike ClientResponse, this value owns its ICAP connection. It is suitable for request-level services and can turn its remaining stream into a Rama Body without spawning a task or copying payload bytes.

Implementations

impl<IO> OwnedClientResponse<IO>

where IO: Io + Unpin + ExtensionsRef,

pub const fn icap(&self) -> &Response

Return the ICAP response metadata.

pub const fn encapsulated(&self) -> Option<&Encapsulated>

Return the typed encapsulated HTTP metadata, when present.

pub fn original_request(&self) -> Option<&Request<()>>

Return the original HTTP request head for a REQMOD transaction.

pub fn original_response(&self) -> Option<&Response<()>>

Return the original HTTP response head for a RESPMOD transaction.

pub fn request(&self) -> Option<&Request<()>>

Return the resulting HTTP request head for a REQMOD transaction.

This applies the same body-only fallback and proxy-field restoration as ClientResponse::request.

pub fn response(&self) -> Option<&Response<()>>

Return the resulting HTTP response head for a RESPMOD transaction.

This applies the same body-only fallback and proxy-field restoration as ClientResponse::response.

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

Read the next zero-copy data or trailer frame.

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

Read the next zero-copy data segment.

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

Return the terminal ICAP body state after the stream completes.

pub const fn trailers(&self) -> Option<&HeaderMap>

Return trailers after the resulting HTTP stream completes.

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

Return negotiated outer ICAP trailers after the ICAP body completes.

These fields remain outside the resulting HTTP body stream.

pub const fn original_body_offset_is_verified(&self) -> Option<bool>

Return whether a 206 original-body offset was locally verified.

pub const fn original_body_bytes_sent(&self) -> u64

Return original entity-body bytes sent in complete ICAP chunks.

pub const fn original_body_len(&self) -> Option<u64>

Return the exact original entity-body length, when known.

pub async fn drain(&mut self) -> Result<(), Error>

Drain and discard the resulting HTTP entity body.

pub fn into_body(self) -> Body

Turn the remaining resulting HTTP stream into a Rama body.

pub fn into_request(self) -> Result<Request, Error>

Turn a successful REQMOD result into a streaming HTTP request.

pub fn into_response(self) -> Result<Response, Error>

Turn a successful RESPMOD result into a streaming HTTP response.

pub fn into_icap(self) -> Result<Response, Error>

Return the ICAP response after its body has completed.

Trait Implementations

impl<IO> Debug for OwnedClientResponse<IO>

where IO: Io + Unpin + ExtensionsRef,

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

Formats the value using the given formatter.

impl<IO> ExtensionsRef for OwnedClientResponse<IO>

fn extensions(&self) -> &Extensions

Get reference to the underlying Extensions store