Struct edjx::stream::ReadStream

source ·

pub struct ReadStream { /* private fields */ }

Expand description

ReadStream is used to receive streamed data.

Implementations§

source §

impl ReadStream

source

pub fn read_chunk(&mut self) -> Option<Result<Vec<u8>, StreamError>>

Reads a chunk of binary data from the stream.

Examples found in repository ?

src/stream.rs (line 161)

    pub fn read_all(&mut self) -> Result<Vec<u8>, StreamError> {
        let mut all_bytes = Vec::new();

        while let Some(bytes_res) = self.read_chunk() {
            match bytes_res {
                Ok(mut bytes) => all_bytes.append(&mut bytes),
                Err(err) => {
                    return Err(err);
                }
            }
        }

        return Ok(all_bytes);
    }

source

pub fn pipe_to(&mut self, ws: &mut WriteStream) -> Result<(), StreamError>

Pipes a read stream into a write stream. After all data is transmitted, both streams are closed.

source

pub fn read_all(&mut self) -> Result<Vec<u8>, StreamError>

Reads and returns all data from the stream until the end of stream.

This method does not close the stream.

Examples found in repository ?

src/fetch_response.rs (line 51)

    pub fn read_body(&mut self) -> Result<Vec<u8>, StreamError> {
        let result = self.read_stream.read_all();
        let closed = self.read_stream.close();

        if result.is_err() {
            return result;
        }

        if closed.is_err() {
            return Err(closed.err().unwrap());
        }

        return result;
    }

More examples

Hide additional examples

src/storage_response.rs (line 67)

    pub fn read_body(&mut self) -> Result<Vec<u8>, StreamError> {
        let result = self.read_stream.read_all();
        let closed = self.read_stream.close();

        if result.is_err() {
            return result;
        }

        if closed.is_err() {
            return Err(closed.err().unwrap());
        }

        return result;
    }