Struct StreamRequestBuilder 

pub struct StreamRequestBuilder<'a> { /* private fields */ }

Stream request builder for fluent API

Implementations

impl<'a> StreamRequestBuilder<'a>

pub fn json_body(self, body: &Value) -> Self

Set JSON body

pub fn timeout(self, timeout: Duration) -> Self

Set custom timeout

pub fn header<K, V>(self, key: K, value: V) -> Self

where K: Into<String>, V: Into<String>,

Add custom header

pub async fn send(self) -> Result<StreamResponse>

Send the streaming request

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

where T: DeserializeOwned + Send,

Send and get JSON results automatically (convenience method)

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

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

Send and process lines with a handler (convenience method)