Lines Matching refs:DynOutputStream
3 use crate::streams::{DynInputStream, DynOutputStream, StreamError, StreamResult};
121 async fn drop(&mut self, stream: Resource<DynOutputStream>) -> Result<()> { in drop()
126 fn check_write(&mut self, stream: Resource<DynOutputStream>) -> StreamResult<u64> { in check_write()
131 fn write(&mut self, stream: Resource<DynOutputStream>, bytes: Vec<u8>) -> StreamResult<()> { in write() argument
136 fn subscribe(&mut self, stream: Resource<DynOutputStream>) -> Result<Resource<DynPollable>> { in subscribe()
142 stream: Resource<DynOutputStream>, in blocking_write_and_flush() argument
158 stream: Resource<DynOutputStream>, in blocking_write_zeroes_and_flush() argument
173 fn write_zeroes(&mut self, stream: Resource<DynOutputStream>, len: u64) -> StreamResult<()> { in write_zeroes() argument
178 fn flush(&mut self, stream: Resource<DynOutputStream>) -> StreamResult<()> { in flush()
183 async fn blocking_flush(&mut self, stream: Resource<DynOutputStream>) -> StreamResult<()> { in blocking_flush()
192 dest: Resource<DynOutputStream>, in splice() argument
221 dest: Resource<DynOutputStream>, in blocking_splice() argument