Enum StreamingResponse 

pub enum StreamingResponse<'a> {
    H2(H2StreamingResponse<'a>),
    H1(H1StreamingResponse<'a>),
}

A streaming HTTP response that yields body chunks incrementally.

Wraps either an HTTP/2 or HTTP/1.1 streaming response. The connection is borrowed exclusively while this type exists — no other requests can be sent until the body is fully consumed or the response is dropped.

Example

let mut stream = client.post("/v1/chat/completions")
    .header("content-type", "application/json")
    .body(payload)
    .send_streaming()
    .await?;

assert_eq!(stream.status(), 200);
while let Some(chunk) = stream.next_chunk().await? {
    // process each body chunk as it arrives
}

Variants

H2(H2StreamingResponse<'a>)

H1(H1StreamingResponse<'a>)

Implementations

impl StreamingResponse<'_>

pub fn status(&self) -> u16

HTTP status code.

pub fn headers(&self) -> &[(String, String)]

Response headers as (name, value) pairs.

pub fn header(&self, name: &str) -> Option<&str>

Get the first header value matching name (case-insensitive).

pub async fn next_chunk(&mut self) -> Result<Option<Bytes>, HttpError>

Yield the next body chunk, or None when the body is complete.