Struct edjx::FetchResponsePending

source ·

pub struct FetchResponsePending { /* private fields */ }

Expand description

FetchResponsePending is a placeholder for the HTTP server’s response. It is returned when crate::fetch::HttpFetch::send_streaming is called. It is then used to retrive FetchResponse from the server.

Example

use edjx::{HttpFetch, FetchResponse, BaseStream, Uri};
use std::str::FromStr;

let fetch_uri = Uri::from_str("https://httpbin.org/post").unwrap();
let (fet_resp_pending, mut write_stream) = HttpFetch::post(fetch_uri).send_streaming().unwrap();

write_stream.write_chunk_text("Chunk text").unwrap();
write_stream.close().unwrap();

let mut fetch_res: FetchResponse = fet_resp_pending.get_fetch_response().unwrap();

Implementations§

source §

impl FetchResponsePending

source

pub fn new(stream_desc: u32) -> Self

Examples found in repository ?

src/fetch.rs (line 335)

    pub fn send_streaming(&self) -> Result<(FetchResponsePending, WriteStream), HttpError> {
        let headers_vec =
            serde_json::to_vec(&super::utils::convert_to_hashmap(&self.parts.headers)).unwrap();
        let headers_slice = headers_vec.as_slice();
        let version: String = super::utils::to_version_string(&self.parts.version);
        let method: String = self.parts.method.as_str().to_string();
        let uri: String = self.parts.uri.to_string();

        let mut error_code: i32 = 0;
        let mut sd: u32 = 0;

        let response_value = unsafe {
            host_fetch_send_streaming(
                version.as_ptr(),
                version.len() as u32,
                headers_slice.as_ptr(),
                headers_slice.len() as u32,
                uri.as_ptr(),
                uri.len() as u32,
                method.as_ptr(),
                method.len() as u32,
                &mut sd,
                &mut error_code,
            )
        };

        if response_value < 0 {
            return Err(HttpError::from(Error::from_i32(error_code).unwrap()));
        }

        Ok((FetchResponsePending::new(sd), BaseStream::new(sd)))
    }