Trait edjx::stream::BaseStream

source · 
pub trait BaseStream {
    fn sd(&self) -> u32;

    fn close(&self) -> Result<(), StreamError> { ... }
}
Expand description

A base stream trait that defines a common stream interface.

Required Methods§

Get the stream descriptor of this stream

Provided Methods§

Cleanly close the stream

Examples found in repository?
src/fetch_response.rs (line 52)
50
51
52
53
54
55
56
57
58
59
60
61
62
63

    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 68)
66
67
68
69
70
71
72
73
74
75
76
77
78
79

    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;
    }

Implementors§