Home
last modified time | relevance | path

Searched refs:FutureReader (Results 1 – 24 of 24) sorted by relevance

/wasmtime-44.0.1/tests/all/component_model/
H A Dasync_dynamic.rs1 use wasmtime::component::{Component, FutureAny, FutureReader, Linker, StreamAny, StreamReader};
11 let f = FutureReader::new(&mut store, async { wasmtime::error::Ok(10_u32) })?; in simple_type_conversions()
81 instance.get_typed_func::<(FutureReader<u32>,), (FutureReader<u32>,)>(&mut store, "f")?; in simple_type_assertions()
82 let f_t_a = instance.get_typed_func::<(FutureReader<u32>,), (FutureAny,)>(&mut store, "f")?; in simple_type_assertions()
92 let mk_f_t = instance.get_typed_func::<(), (FutureReader<u32>,)>(&mut store, "mk-f")?; in simple_type_assertions()
100 .get_typed_func::<(u32,), (FutureReader<u32>,)>(&mut store, "f") in simple_type_assertions()
105 .get_typed_func::<(FutureReader<u32>,), (u32,)>(&mut store, "f") in simple_type_assertions()
110 .get_typed_func::<(FutureReader<()>,), (FutureReader<u32>,)>(&mut store, "f") in simple_type_assertions()
115 .get_typed_func::<(FutureReader<u64>,), (FutureReader<u32>,)>(&mut store, "f") in simple_type_assertions()
141 let roundtrip = |store: &mut Store<()>, f: FutureReader<u32>| -> Result<()> { in simple_type_assertions()
[all …]
H A Dasync.rs736 let func = instance.get_typed_func::<(FutureReader<u32>,), ()>(&mut store, "run")?; in cancel_host_future()
737 let reader = FutureReader::new(&mut store, MyFutureReader)?; in cancel_host_future()
848 assert!(FutureReader::new(&mut store, async { wasmtime::error::Ok(0) }).is_err()); in require_concurrency_support()
/wasmtime-44.0.1/crates/test-programs/src/bin/
H A Dasync_closed_streams.rs15 wit_bindgen::{FutureReader, StreamReader, StreamResult},
33 async fn read_future(rx: FutureReader<u8>, expected: u8, _rx_ignored: FutureReader<u8>) { in read_future()
38 rx: FutureReader<u8>, in read_future_post_return()
40 _rx_ignored: FutureReader<u8>, in read_future_post_return()
H A Dasync_transmit_callee.rs17 wit_bindgen::{FutureReader, StreamReader, StreamResult},
26 caller_future_rx1: FutureReader<String>, in exchange()
27 caller_future_rx2: FutureReader<String>, in exchange()
30 FutureReader<String>, in exchange()
31 FutureReader<String>, in exchange()
H A Dp3_http_outbound_request_content_length.rs5 use wit_bindgen::{FutureReader, FutureWriter, StreamWriter};
15 FutureReader<Result<(), ErrorCode>>, in make_request()
H A Dp3_sockets_tcp_streams.rs9 use wit_bindgen::{FutureReader, StreamReader, StreamResult, StreamWriter};
305 receive_result: FutureReader<Result<(), ErrorCode>>,
307 send_result: FutureReader<Result<(), ErrorCode>>,
H A Dfuzz_async.rs153 use wit_bindgen::{FutureReader, FutureWriter, StreamReader, StreamResult, StreamWriter};
211 fn future_take(id: u32) -> FutureReader<u32> { in future_take()
215 fn future_receive(id: u32, f: FutureReader<u32>) { in future_receive()
237 future_readers: HashMap<u32, FutureReader<u32>>,
468 type Output = Result<u32, FutureReader<u32>>; in run()
/wasmtime-44.0.1/crates/misc/component-async-tests/tests/scenario/
H A Dtransmit.rs543 caller_future1: FutureReader<String>, in into_params()
552 FutureReader<String>, in from_result()
553 FutureReader<String>, in from_result()
564 FutureReader<String>,
565 FutureReader<String>,
569 FutureReader<String>,
570 FutureReader<String>,
606 FutureReader<String>, in from_result()
607 FutureReader<String>, in from_result()
681 FutureReader<String>, in from_result()
[all …]
H A Dstreams.rs22 Destination, FutureReader, Lift, Linker, ResourceTable, Source, StreamConsumer,
186 FutureReader::new(&mut store, OneshotProducer::new(input_rx))? in async_closed_streams()
233 let rx = FutureReader::new(&mut store, OneshotProducer::new(rx))?; in async_closed_streams()
235 let rx_ignored = FutureReader::new(&mut store, OneshotProducer::new(rx_ignored))?; in async_closed_streams()
/wasmtime-44.0.1/crates/wasi/src/p3/cli/
H A Dhost.rs17 Access, Destination, FutureReader, Resource, Source, StreamConsumer, StreamProducer,
197 ) -> wasmtime::Result<(StreamReader<u8>, FutureReader<Result<(), ErrorCode>>)> { in read_via_stream()
207 let future = FutureReader::new(&mut store, async { in read_via_stream()
223 ) -> wasmtime::Result<FutureReader<Result<(), ErrorCode>>> { in write_via_stream()
233 FutureReader::new(&mut store, async { in write_via_stream()
248 ) -> wasmtime::Result<FutureReader<Result<(), ErrorCode>>> { in write_via_stream()
258 FutureReader::new(&mut store, async { in write_via_stream()
/wasmtime-44.0.1/crates/wasi-tls/src/p3/
H A Dhost.rs11 Access, Accessor, AccessorTask, FutureProducer, FutureReader, HasData, Resource, StreamReader,
55 ) -> wasmtime::Result<(StreamReader<u8>, FutureReader<Result<(), Resource<Error>>>)> { in send()
70 FutureReader::new(&mut store, result)?, in send()
109 FutureReader::new(&mut store, result)?, in send()
117 ) -> wasmtime::Result<(StreamReader<u8>, FutureReader<Result<(), Resource<Error>>>)> { in receive()
132 FutureReader::new(&mut store, result)?, in receive()
175 FutureReader::new(&mut store, result)?, in receive()
/wasmtime-44.0.1/crates/wasi-http/src/p3/host/
H A Dtypes.rs17 Access, FutureProducer, FutureReader, Resource, ResourceTable, StreamReader,
314 trailers: FutureReader<Result<Option<Resource<Trailers>>, ErrorCode>>, in new()
316 ) -> wasmtime::Result<(Resource<Request>, FutureReader<Result<(), ErrorCode>>)> { in new()
353 FutureReader::new(&mut store, GuestBodyResultProducer::Receiver(result_rx))?, in new()
360 fut: FutureReader<Result<(), ErrorCode>>, in consume_body()
363 FutureReader<Result<Option<Resource<Trailers>>, ErrorCode>>, in consume_body()
597 trailers: FutureReader<Result<Option<Resource<Trailers>>, ErrorCode>>, in new()
598 ) -> wasmtime::Result<(Resource<Response>, FutureReader<Result<(), ErrorCode>>)> { in new()
630 FutureReader::new(&mut store, GuestBodyResultProducer::Receiver(result_rx))?, in new()
637 fut: FutureReader<Result<(), ErrorCode>>, in consume_body()
[all …]
/wasmtime-44.0.1/crates/wasi/src/p3/sockets/host/types/
H A Dtcp.rs20 Access, Accessor, Destination, FutureReader, Resource, ResourceTable, Source, StreamConsumer,
298 ) -> wasmtime::Result<FutureReader<Result<(), ErrorCode>>> { in send()
310 FutureReader::new(&mut store, result_rx) in send()
314 FutureReader::new(&mut store, async { wasmtime::error::Ok(Err(err.into())) }) in send()
322 ) -> wasmtime::Result<(StreamReader<u8>, FutureReader<Result<(), ErrorCode>>)> { in receive()
335 FutureReader::new(&mut store, result_rx)?, in receive()
340 FutureReader::new(&mut store, async { wasmtime::error::Ok(Err(err.into())) })?, in receive()
/wasmtime-44.0.1/crates/wasi/src/p3/filesystem/
H A Dhost.rs21 Access, Accessor, Destination, FutureReader, Resource, ResourceTable, Source, StreamConsumer,
501 ) -> wasmtime::Result<(StreamReader<u8>, FutureReader<Result<(), ErrorCode>>)> { in read_via_stream()
506 FutureReader::new(&mut store, async { in read_via_stream()
524 FutureReader::new(&mut store, result_rx)?, in read_via_stream()
533 ) -> wasmtime::Result<FutureReader<Result<(), ErrorCode>>> { in write_via_stream()
553 FutureReader::new(&mut store, result_rx) in write_via_stream()
560 ) -> wasmtime::Result<FutureReader<Result<(), ErrorCode>>> { in append_via_stream()
577 FutureReader::new(&mut store, result_rx) in append_via_stream()
647 FutureReader<Result<(), ErrorCode>>, in read_directory()
683 Ok((stream, FutureReader::new(&mut store, result_rx)?)) in read_directory()
/wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/
H A Dfuture_stream_any.rs9 ComponentInstanceId, ComponentType, FutureReader, Lift, Lower, StreamReader,
72 pub fn try_into_future_reader<T>(self) -> Result<FutureReader<T>> in try_into_future_reader()
78 Ok(FutureReader::new_(self.id)) in try_into_future_reader()
90 reader: FutureReader<T>, in try_from_future_reader()
H A Dfutures_and_streams.rs1160 pub struct FutureReader<T> { struct
1165 impl<T> FutureReader<T> { argument
1372 impl<T> fmt::Debug for FutureReader<T> { implementation
1446 unsafe impl<T: ComponentType> ComponentType for FutureReader<T> { implementation
1463 unsafe impl<T: ComponentType> func::Lower for FutureReader<T> { implementation
1488 unsafe impl<T: ComponentType> func::Lift for FutureReader<T> { implementation
1522 reader: Option<FutureReader<T>>,
1537 pub fn new(accessor: A, reader: FutureReader<T>) -> Self { in new()
1551 pub fn into_future(self) -> FutureReader<T> { in into_future()
1556 impl<T, A> From<GuardedFutureReader<T, A>> for FutureReader<T> implementation
/wasmtime-44.0.1/crates/wasi-http/src/p3/
H A Dbody.rs17 Access, Destination, FutureConsumer, FutureReader, Resource, Source, StreamConsumer,
30 trailers_rx: FutureReader<Result<Option<Resource<Trailers>>, ErrorCode>>,
75 fut: FutureReader<Result<(), ErrorCode>>, in consume()
79 FutureReader<Result<Option<Resource<Trailers>>, ErrorCode>>, in consume()
110 FutureReader::new(&mut store, trailers_rx)?, in consume()
271 trailers_rx: FutureReader<Result<Option<Resource<Trailers>>, ErrorCode>>, in new()
/wasmtime-44.0.1/crates/component-macro/tests/expanded/
H A Drecords.rs355 pub a: wasmtime::component::FutureReader<u8>,
360 wasmtime::component::FutureReader<
365 pub d: wasmtime::component::FutureReader<
367 wasmtime::component::FutureReader<()>,
762 pub a: wasmtime::component::FutureReader<u8>,
767 wasmtime::component::FutureReader<
772 pub d: wasmtime::component::FutureReader<
774 wasmtime::component::FutureReader<()>,
H A Drecords_concurrent.rs355 pub a: wasmtime::component::FutureReader<u8>,
360 wasmtime::component::FutureReader<
365 pub d: wasmtime::component::FutureReader<
367 wasmtime::component::FutureReader<()>,
773 pub a: wasmtime::component::FutureReader<u8>,
778 wasmtime::component::FutureReader<
783 pub d: wasmtime::component::FutureReader<
785 wasmtime::component::FutureReader<()>,
H A Drecords_async.rs355 pub a: wasmtime::component::FutureReader<u8>,
360 wasmtime::component::FutureReader<
365 pub d: wasmtime::component::FutureReader<
367 wasmtime::component::FutureReader<()>,
840 pub a: wasmtime::component::FutureReader<u8>,
845 wasmtime::component::FutureReader<
850 pub d: wasmtime::component::FutureReader<
852 wasmtime::component::FutureReader<()>,
H A Drecords_tracing_async.rs355 pub a: wasmtime::component::FutureReader<u8>,
360 wasmtime::component::FutureReader<
365 pub d: wasmtime::component::FutureReader<
367 wasmtime::component::FutureReader<()>,
1001 pub a: wasmtime::component::FutureReader<u8>,
1006 wasmtime::component::FutureReader<
1011 pub d: wasmtime::component::FutureReader<
1013 wasmtime::component::FutureReader<()>,
/wasmtime-44.0.1/crates/wasmtime/src/runtime/component/
H A Dmod.rs123 ErrorContext, FutureAny, FutureConsumer, FutureProducer, FutureReader, GuardedFutureReader,
H A Dconcurrent.rs100 FutureReader, GuardedFutureReader, GuardedStreamReader, ReadBuffer, Source, StreamConsumer,
/wasmtime-44.0.1/crates/fuzzing/src/oracles/
H A Dcomponent_async.rs17 FutureReader, HasSelf, Linker, ResourceTable, Source, StreamConsumer, StreamProducer,
122 host_futures: HashMap<u32, FutureReader<u32>>,
169 fn future_take(&mut self, id: u32) -> FutureReader<u32> { in future_take()
173 fn future_receive(&mut self, id: u32, future: FutureReader<u32>) { in future_receive()
405 let future = FutureReader::new(&mut s, HostFutureProducer(id, arc)).unwrap(); in future_or_stream_cmd()