Home
last modified time | relevance | path

Searched refs:StreamReader (Results 1 – 25 of 27) sorted by relevance

12

/wasmtime-44.0.1/tests/all/component_model/
H A Dasync_dynamic.rs1 use wasmtime::component::{Component, FutureAny, FutureReader, Linker, StreamAny, StreamReader};
20 let s = StreamReader::new(&mut store, vec![10_u32])?; in simple_type_conversions()
87 instance.get_typed_func::<(StreamReader<u32>,), (StreamReader<u32>,)>(&mut store, "s")?; in simple_type_assertions()
88 let s_t_a = instance.get_typed_func::<(StreamReader<u32>,), (StreamAny,)>(&mut store, "s")?; in simple_type_assertions()
94 let mk_s_t = instance.get_typed_func::<(), (StreamReader<u32>,)>(&mut store, "mk-s")?; in simple_type_assertions()
122 .get_typed_func::<(u32,), (StreamReader<u32>,)>(&mut store, "s") in simple_type_assertions()
127 .get_typed_func::<(StreamReader<u32>,), (u32,)>(&mut store, "s") in simple_type_assertions()
132 .get_typed_func::<(StreamReader<()>,), (StreamReader<u32>,)>(&mut store, "s") in simple_type_assertions()
137 .get_typed_func::<(StreamReader<u64>,), (StreamReader<u32>,)>(&mut store, "s") in simple_type_assertions()
160 let roundtrip = |store: &mut Store<()>, s: StreamReader<u32>| -> Result<()> { in simple_type_assertions()
[all …]
H A Dasync.rs847 assert!(StreamReader::<u32>::new(&mut store, Vec::new()).is_err()); in require_concurrency_support()
1148 let func = instance.get_typed_func::<(StreamReader<u8>,), ()>(&mut store, "run")?; in stream_cancel_read_async_does_not_corrupt_state()
1152 let reader = StreamReader::new(&mut store, NeverWriteStreamProducer)?; in stream_cancel_read_async_does_not_corrupt_state()
1309 let func = instance.get_typed_func::<(StreamReader<u8>, u32), (u32,)>(&mut store, "read")?; in bytes_stream_producer()
1312 let reader = StreamReader::new(&mut store, bytes::Bytes::from_static(b"hello"))?; in bytes_stream_producer()
1319 let reader = StreamReader::new(&mut store, bytes::Bytes::from_static(b"hello"))?; in bytes_stream_producer()
/wasmtime-44.0.1/crates/test-programs/src/bin/
H A Dasync_transmit_callee.rs17 wit_bindgen::{FutureReader, StreamReader, StreamResult},
24 mut control_rx: StreamReader<Control>, in exchange()
25 mut caller_stream_rx: StreamReader<String>, in exchange()
29 StreamReader<String>, in exchange()
H A Dasync_short_reads.rs6 wit_bindgen::{StreamReader, StreamResult, rt::async_support},
39 mut stream: StreamReader<short_reads::Thing>, in short_reads()
40 ) -> StreamReader<short_reads::Thing> { in short_reads()
H A Dasync_closed_stream.rs11 use {bindings::exports::local::local::closed_stream::Guest, wit_bindgen::StreamReader};
16 fn get() -> StreamReader<u8> { in get()
H A Dasync_unit_stream_callee.rs13 wit_bindgen::StreamReader,
19 async fn run(count: u32) -> StreamReader<()> { in run() argument
H A Dasync_closed_streams.rs15 wit_bindgen::{FutureReader, StreamReader, StreamResult},
21 async fn read_stream(mut rx: StreamReader<u8>, expected: Vec<u8>) { in read_stream()
H A Dfuzz_async.rs153 use wit_bindgen::{FutureReader, FutureWriter, StreamReader, StreamResult, StreamWriter};
220 fn stream_take(id: u32) -> StreamReader<u32> { in stream_take()
224 fn stream_receive(id: u32, f: StreamReader<u32>) { in stream_receive()
244 stream_readers: HashMap<u32, StreamReader<u32>>,
274 async fn run(mut commands: StreamReader<Command>) { in run()
H A Dp3_sockets_tcp_streams.rs9 use wit_bindgen::{FutureReader, StreamReader, StreamResult, StreamWriter};
304 receive_stream: StreamReader<u8>,
/wasmtime-44.0.1/crates/wasi-tls/src/p3/
H A Dhost.rs11 Access, Accessor, AccessorTask, FutureProducer, FutureReader, HasData, Resource, StreamReader,
54 mut cleartext: StreamReader<u8>, in send()
55 ) -> wasmtime::Result<(StreamReader<u8>, FutureReader<Result<(), Resource<Error>>>)> { in send()
69 StreamReader::new(&mut store, ciphertext)?, in send()
108 StreamReader::new(&mut store, ciphertext)?, in send()
116 mut ciphertext: StreamReader<u8>, in receive()
117 ) -> wasmtime::Result<(StreamReader<u8>, FutureReader<Result<(), Resource<Error>>>)> { in receive()
131 StreamReader::new(&mut store, cleartext)?, in receive()
174 StreamReader::new(&mut store, cleartext)?, in receive()
/wasmtime-44.0.1/crates/misc/component-async-tests/src/
H A Dresource_stream.rs4 use wasmtime::component::{Accessor, Resource, StreamReader};
40 ) -> wasmtime::Result<StreamReader<Resource<ResourceStreamX>>> { in foo()
47 StreamReader::new(access, PipeProducer::new(rx)) in foo()
/wasmtime-44.0.1/crates/misc/component-async-tests/tests/scenario/
H A Dtransmit.rs357 let rx = StreamReader::new( in async_readiness()
541 control: StreamReader<Control>, in into_params()
542 caller_stream: StreamReader<String>, in into_params()
551 StreamReader<String>, in from_result()
562 StreamReader<Control>,
563 StreamReader<String>,
568 StreamReader<String>,
593 control: StreamReader<Control>, in into_params()
605 StreamReader<String>, in from_result()
654 control: StreamReader<Control>, in into_params()
[all …]
H A Dstreams.rs23 StreamProducer, StreamReader, StreamResult, VecBuffer,
146 StreamReader::new(&mut store, DirectPipeProducer(input_rx))? in async_closed_streams()
148 StreamReader::new(&mut store, PipeProducer::new(input_rx))? in async_closed_streams()
201 let rx = StreamReader::new(&mut store, PipeProducer::new(rx))?; in async_closed_streams()
432 store.with(|store| StreamReader::new(store, VecProducer::new(things, delay)))?; in test_async_short_reads()
/wasmtime-44.0.1/crates/wasi/src/p3/cli/
H A Dhost.rs18 StreamReader, StreamResult,
197 ) -> wasmtime::Result<(StreamReader<u8>, FutureReader<Result<(), ErrorCode>>)> { in read_via_stream()
200 let stream = StreamReader::new( in read_via_stream()
222 data: StreamReader<u8>, in write_via_stream()
247 data: StreamReader<u8>, in write_via_stream()
/wasmtime-44.0.1/crates/wasi/src/p3/sockets/host/types/
H A Dtcp.rs21 StreamProducer, StreamReader, StreamResult,
274 ) -> SocketResult<StreamReader<Resource<TcpSocket>>> { in listen()
281 let ret = StreamReader::new( in listen()
297 mut data: StreamReader<u8>, in send()
322 ) -> wasmtime::Result<(StreamReader<u8>, FutureReader<Result<(), ErrorCode>>)> { in receive()
328 StreamReader::new( in receive()
339 StreamReader::new(&mut store, iter::empty())?, in receive()
/wasmtime-44.0.1/crates/wasi/src/p3/filesystem/
H A Dhost.rs22 StreamProducer, StreamReader, StreamResult,
501 ) -> wasmtime::Result<(StreamReader<u8>, FutureReader<Result<(), ErrorCode>>)> { in read_via_stream()
505 StreamReader::new(&mut store, iter::empty())?, in read_via_stream()
515 StreamReader::new( in read_via_stream()
531 mut data: StreamReader<u8>, in write_via_stream()
559 mut data: StreamReader<u8>, in append_via_stream()
646 StreamReader<DirectoryEntry>, in read_directory()
662 Ok(readdir) => StreamReader::new( in read_directory()
671 StreamReader::new(&mut store, iter::empty())? in read_directory()
675 StreamReader::new(&mut store, ReadDirStream::new(dir, result_tx))? in read_directory()
[all …]
/wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/
H A Dfuture_stream_any.rs9 ComponentInstanceId, ComponentType, FutureReader, Lift, Lower, StreamReader,
244 pub fn try_into_stream_reader<T>(self) -> Result<StreamReader<T>> in try_into_stream_reader()
250 Ok(StreamReader::new_(self.id)) in try_into_stream_reader()
262 reader: StreamReader<T>, in try_from_stream_reader()
/wasmtime-44.0.1/crates/wasi-http/src/p3/
H A Dbody.rs18 StreamProducer, StreamReader, StreamResult,
28 contents_rx: Option<StreamReader<u8>>,
78 StreamReader<u8>, in consume()
96 (StreamReader::new(&mut store, iter::empty())?, trailers_rx) in consume()
102 StreamReader::new( in consume()
270 contents_rx: Option<StreamReader<u8>>, in new()
/wasmtime-44.0.1/crates/component-macro/tests/expanded/
H A Drecords.rs357 pub b: wasmtime::component::StreamReader<u8>,
359 pub c: wasmtime::component::StreamReader<
361 wasmtime::component::StreamReader<()>,
366 wasmtime::component::StreamReader<
764 pub b: wasmtime::component::StreamReader<u8>,
766 pub c: wasmtime::component::StreamReader<
768 wasmtime::component::StreamReader<()>,
773 wasmtime::component::StreamReader<
H A Drecords_concurrent.rs357 pub b: wasmtime::component::StreamReader<u8>,
359 pub c: wasmtime::component::StreamReader<
361 wasmtime::component::StreamReader<()>,
366 wasmtime::component::StreamReader<
775 pub b: wasmtime::component::StreamReader<u8>,
777 pub c: wasmtime::component::StreamReader<
779 wasmtime::component::StreamReader<()>,
784 wasmtime::component::StreamReader<
H A Drecords_async.rs357 pub b: wasmtime::component::StreamReader<u8>,
359 pub c: wasmtime::component::StreamReader<
361 wasmtime::component::StreamReader<()>,
366 wasmtime::component::StreamReader<
842 pub b: wasmtime::component::StreamReader<u8>,
844 pub c: wasmtime::component::StreamReader<
846 wasmtime::component::StreamReader<()>,
851 wasmtime::component::StreamReader<
H A Drecords_tracing_async.rs357 pub b: wasmtime::component::StreamReader<u8>,
359 pub c: wasmtime::component::StreamReader<
361 wasmtime::component::StreamReader<()>,
366 wasmtime::component::StreamReader<
1003 pub b: wasmtime::component::StreamReader<u8>,
1005 pub c: wasmtime::component::StreamReader<
1007 wasmtime::component::StreamReader<()>,
1012 wasmtime::component::StreamReader<
/wasmtime-44.0.1/crates/fuzzing/src/oracles/
H A Dcomponent_async.rs18 StreamReader, StreamResult, VecBuffer,
112 guest_caller_stream: Option<StreamReader<Command>>,
113 guest_callee_stream: Option<StreamReader<Command>>,
125 host_streams: HashMap<u32, StreamReader<u32>>,
178 fn stream_take(&mut self, id: u32) -> StreamReader<u32> { in stream_take()
182 fn stream_receive(&mut self, id: u32, stream: StreamReader<u32>) { in stream_receive()
192 ) -> StreamReader<Command> { in get_commands()
225 StreamReader::new(&mut store, SharedStream(Scope::GuestCaller)).unwrap(); in run()
227 StreamReader::new(&mut store, SharedStream(Scope::GuestCallee)).unwrap(); in run()
552 let stream = StreamReader::new(&mut s, HostStreamProducer(id, arc)).unwrap(); in future_or_stream_cmd()
/wasmtime-44.0.1/crates/wasi-http/src/p3/host/
H A Dtypes.rs17 Access, FutureProducer, FutureReader, Resource, ResourceTable, StreamReader,
313 contents: Option<StreamReader<u8>>, in new()
362 StreamReader<u8>, in consume_body()
596 contents: Option<StreamReader<u8>>, in new()
639 StreamReader<u8>, in consume_body()
/wasmtime-44.0.1/crates/wasmtime/src/runtime/component/
H A Dmod.rs125 StreamReader, StreamResult, VMComponentAsyncStore, VecBuffer, WriteBuffer,

12