Searched refs:StreamAny (Results 1 – 7 of 7) sorted by relevance
| /wasmtime-44.0.1/tests/all/component_model/ |
| H A D | async_dynamic.rs | 1 use wasmtime::component::{Component, FutureAny, FutureReader, Linker, StreamAny, StreamReader};
88 let s_t_a = instance.get_typed_func::<(StreamReader<u32>,), (StreamAny,)>(&mut store, "s")?; in simple_type_assertions()
89 let s_a_t = instance.get_typed_func::<(StreamAny,), (StreamReader<u32>,)>(&mut store, "s")?; in simple_type_assertions()
90 let s_a_a = instance.get_typed_func::<(StreamAny,), (StreamAny,)>(&mut store, "s")?; in simple_type_assertions()
95 let mk_s_a = instance.get_typed_func::<(), (StreamAny,)>(&mut store, "mk-s")?; in simple_type_assertions()
266 let mk = instance.get_typed_func::<(), (StreamAny,)>(&mut store, "mk")?; in stream_any_smoke()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/ |
| H A D | concurrent_disabled.rs | 115 pub struct StreamAny(Infallible); struct
117 unsafe impl ComponentType for StreamAny { implementation
126 unsafe impl Lift for StreamAny { implementation
144 unsafe impl Lower for StreamAny { implementation
|
| H A D | mod.rs | 124 GuardedStreamReader, JoinHandle, ReadBuffer, Source, StreamAny, StreamConsumer, StreamProducer,
|
| H A D | values.rs | 3 use crate::component::concurrent::{self, ErrorContext, FutureAny, StreamAny};
94 Stream(StreamAny),
218 Val::Stream(StreamAny::linear_lift_from_flat(cx, ty, next(src))?) in lift()
348 InterfaceType::Stream(_) => StreamAny::linear_lift_from_memory(cx, ty, bytes)?.into(), in load()
1294 impl From<StreamAny> for Val {
1295 fn from(i: StreamAny) -> Self { in from()
|
| H A D | concurrent.rs | 97 pub use future_stream_any::{FutureAny, StreamAny};
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/ |
| H A D | future_stream_any.rs | 215 pub struct StreamAny { struct
220 impl StreamAny { argument
273 Ok(StreamAny { in try_from_stream_reader()
285 Ok(StreamAny { in lift_from_index()
311 unsafe impl ComponentType for StreamAny { implementation
324 unsafe impl Lower for StreamAny { implementation
346 unsafe impl Lift for StreamAny { implementation
|
| H A D | futures_and_streams.rs | 9 AsAccessor, ComponentInstanceId, ComponentType, FutureAny, Instance, Lift, Lower, StreamAny,
1736 pub fn try_into_stream_any(self, store: impl AsContextMut) -> Result<StreamAny> in try_into_stream_any()
1740 StreamAny::try_from_stream_reader(store, self) in try_into_stream_any()
1749 pub fn try_from_stream_any(stream: StreamAny) -> Result<Self> in try_from_stream_any()
|