Home
last modified time | relevance | path

Searched defs:StreamError (Results 1 – 14 of 14) sorted by relevance

/wasmtime-44.0.1/crates/wasi-io/src/
H A Dstreams.rs86 pub enum StreamError { enum
92 impl StreamError { impl
93 pub fn trap(msg: &str) -> StreamError { in trap()
98 impl alloc::fmt::Display for StreamError { implementation
108 impl core::error::Error for StreamError { implementation
117 impl From<wasmtime::component::ResourceTableError> for StreamError { implementation
H A Dimpls.rs98 fn convert_stream_error(&mut self, err: StreamError) -> Result<streams::StreamError> { in convert_stream_error()
/wasmtime-44.0.1/crates/wasi/src/p2/
H A Dtcp.rs61 fn read(&mut self, size: usize) -> Result<bytes::Bytes, StreamError> { in read() argument
110 fn read(&mut self, size: usize) -> Result<bytes::Bytes, StreamError> { in read() argument
186 fn write(&mut self, mut bytes: bytes::Bytes) -> Result<(), StreamError> { in write() argument
222 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
235 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() argument
316 fn write(&mut self, bytes: bytes::Bytes) -> Result<(), StreamError> { in write() argument
320 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
324 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() argument
346 fn try_lock_for_stream<T>(mutex: &Mutex<T>) -> Result<tokio::sync::MutexGuard<'_, T>, StreamError> { in try_lock_for_stream() argument
H A Dpipe.rs43 fn read(&mut self, size: usize) -> Result<Bytes, StreamError> { in read() argument
99 fn write(&mut self, bytes: Bytes) -> Result<(), StreamError> { in write() argument
110 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
114 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() argument
208 fn read(&mut self, size: usize) -> Result<Bytes, StreamError> { in read() argument
278 fn write(&mut self, _buf: Bytes) -> Result<(), StreamError> { in write() argument
281 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
286 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() argument
319 fn write(&mut self, _: Bytes) -> Result<(), StreamError> { in write() argument
322 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
[all …]
H A Dwrite_stream.rs19 fn check_error(&mut self) -> Result<(), StreamError> { in check_error() argument
54 fn check_write(&self) -> Result<usize, StreamError> { in check_write() argument
168 fn write(&mut self, bytes: Bytes) -> Result<(), StreamError> { in write() argument
187 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
197 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() argument
H A Dfilesystem.rs284 fn write(&mut self, buf: Bytes) -> Result<(), StreamError> { in write() argument
337 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
350 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() argument
/wasmtime-44.0.1/crates/wasi/src/cli/
H A Dlocked_async.rs81 fn read(&mut self, size: usize) -> Result<bytes::Bytes, p2::StreamError> { in read()
87 fn skip(&mut self, size: usize) -> Result<usize, p2::StreamError> { in skip()
179 fn check_write(&mut self) -> Result<usize, p2::StreamError> { in check_write()
185 fn write(&mut self, bytes: Bytes) -> Result<(), p2::StreamError> { in write()
191 fn flush(&mut self) -> Result<(), p2::StreamError> { in flush()
H A Dworker_thread_stdin.rs140 fn read(&mut self, size: usize) -> Result<Bytes, StreamError> { in read() argument
/wasmtime-44.0.1/crates/wasi/src/p2/host/
H A Dio.rs13 impl From<async_streams::StreamError> for streams::StreamError { implementation
23 fn convert_stream_error(&mut self, err: StreamError) -> wasmtime::Result<streams::StreamError> { in convert_stream_error()
/wasmtime-44.0.1/crates/c-api/src/
H A Dwasi.rs200 fn write(&mut self, bytes: Bytes) -> Result<(), StreamError> { in write() argument
214 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
217 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() argument
/wasmtime-44.0.1/crates/wasi-http/src/p2/
H A Dbody.rs237 fn read(&mut self, size: usize) -> Result<Bytes, StreamError> { in read() argument
609 fn write(&mut self, bytes: Bytes) -> Result<(), StreamError> { in write() argument
639 fn flush(&mut self) -> Result<(), StreamError> { in flush() argument
649 fn check_write(&mut self) -> Result<usize, StreamError> { in check_write() argument
/wasmtime-44.0.1/crates/wasi-tls/src/p2/
H A Dio.rs223 fn try_lock(&self) -> Result<tokio::sync::MutexGuard<'_, WriteState<IO>>, StreamError> { in try_lock() argument
/wasmtime-44.0.1/crates/test-programs/src/
H A Dsockets.rs50 pub fn blocking_write_util(&self, mut bytes: &[u8]) -> Result<(), StreamError> { in blocking_write_util() argument
/wasmtime-44.0.1/crates/wasi-preview1-component-adapter/src/
H A Dlib.rs2570 ) -> Result<Vec<u8>, streams::StreamError> { in read()