Struct StreamResponse

pub struct StreamResponse { /* private fields */ }

Stream response wrapper with chainable methods

Implementations

impl StreamResponse

pub fn status(&self) -> u16

Get the HTTP status code

pub fn is_success(&self) -> bool

Check if response indicates success (2xx status)

pub fn is_client_error(&self) -> bool

Check if response indicates client error (4xx status)

pub fn is_server_error(&self) -> bool

Check if response indicates server error (5xx status)

pub async fn json_results<T>(self) -> Result<Vec<T>>

where T: DeserializeOwned + Send,

Convert stream to JSON objects with automatic parsing and timeout

pub async fn json<T>(self, timeout: Duration) -> Result<Vec<T>>

where T: DeserializeOwned + Send,

Convert stream to JSON objects with custom timeout

pub async fn process_lines<F>(self, timeout: Duration, handler: F) -> Result<()>

where F: FnMut(&str) -> Result<(), Box<dyn Error + Send + Sync>>,

Process stream in real-time with a handler

pub async fn process_json<F, T>( self, timeout: Duration, handler: F, ) -> Result<Vec<T>>

where F: FnMut(&str) -> Option<T>, T: Send + 'static,

Process stream with custom JSON processing

pub async fn collect_text(self) -> Result<String>

Collect all stream content as text

pub async fn collect_text_with_timeout( self, timeout: Duration, ) -> Result<String>

Collect stream content with timeout

pub fn into_inner(self) -> StreamingResponse

Get the underlying modern StreamingResponse

pub fn headers(&self) -> Value

Get headers as JSON for backward compatibility