Home
last modified time | relevance | path

Searched refs:BytesMut (Results 1 – 12 of 12) sorted by relevance

/wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/futures_and_streams/
H A Dbuffers.rs2 use bytes::{Bytes, BytesMut};
407 unsafe impl WriteBuffer<u8> for Cursor<BytesMut> {
429 impl ReadBuffer<u8> for BytesMut { implementation
495 let mut dst = BytesMut::new(); in test_cursor_bytes_take()
505 let mut buf = Cursor::new(BytesMut::from(&b"123"[..])); in test_cursor_bytes_mut_take()
512 let mut dst = BytesMut::new(); in test_cursor_bytes_mut_take()
/wasmtime-44.0.1/crates/wasi-tls/src/p3/util/
H A Dclosed.rs2 use bytes::BytesMut;
41 type Buffer = Cursor<BytesMut>;
H A Dtokio_streams.rs1 use bytes::BytesMut;
40 type Buffer = Cursor<BytesMut>;
/wasmtime-44.0.1/crates/wasi/src/cli/
H A Dworker_thread_stdin.rs27 use bytes::{Bytes, BytesMut};
83 Data(BytesMut),
108 let mut bytes = BytesMut::zeroed(1024); in create()
H A Dfile.rs127 let mut buf = bytes::BytesMut::zeroed(size.min(crate::MAX_READ_SIZE_ALLOC)); in read()
/wasmtime-44.0.1/crates/wasi/src/p3/filesystem/
H A Dhost.rs10 use bytes::BytesMut;
130 task: Option<JoinHandle<std::io::Result<BytesMut>>>,
163 type Buffer = Cursor<BytesMut>;
365 buffer: BytesMut,
366 task: Option<JoinHandle<std::io::Result<(BytesMut, usize)>>>,
381 buffer: BytesMut::default(), in new_at()
391 buffer: BytesMut::default(), in new_append()
/wasmtime-44.0.1/crates/wasi/src/p3/cli/
H A Dhost.rs10 use bytes::BytesMut;
39 type Buffer = Cursor<BytesMut>;
/wasmtime-44.0.1/crates/wasi/src/p2/
H A Dpipe.rs77 buffer: Arc<Mutex<bytes::BytesMut>>,
84 buffer: std::sync::Arc::new(std::sync::Mutex::new(bytes::BytesMut::new())), in new()
92 pub fn try_into_inner(self) -> Option<bytes::BytesMut> { in try_into_inner() argument
166 let mut buf = bytes::BytesMut::with_capacity(crate::MAX_READ_SIZE_ALLOC); in new()
H A Dfilesystem.rs6 use bytes::{Bytes, BytesMut};
89 let mut buf = BytesMut::zeroed(size.min(crate::MAX_READ_SIZE_ALLOC)); in blocking_read()
H A Dtcp.rs69 let mut buf = bytes::BytesMut::with_capacity(size.min(crate::MAX_READ_SIZE_ALLOC)); in read()
/wasmtime-44.0.1/crates/wasi/src/p3/sockets/host/types/
H A Dtcp.rs9 use bytes::BytesMut;
118 type Buffer = Cursor<BytesMut>;
/wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/
H A Dfutures_and_streams.rs753 impl<D> StreamProducer<D> for bytes::BytesMut { implementation