| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/component/ |
| H A D | handle_table.rs | 46 Stream, enumerator
91 Stream { enumerator
283 self.insert(Slot::Stream { in stream_insert_read()
295 self.insert(Slot::Stream { in stream_insert_write()
313 Slot::Stream { rep, ty, state } => { in stream_rep()
336 Slot::Stream { rep, ty, state } => { in stream_remove_readable()
362 Slot::Stream { rep, ty, state } => { in stream_remove_writable()
571 Slot::Stream { rep, .. } => Ok((*rep, Waitable::Stream)), in waitable_rep()
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p2_api_proxy_streaming.rs | 308 use futures::{Sink, Stream, future, sink, stream};
467 pub fn incoming_body(body: IncomingBody) -> impl Stream<Item = Result<Vec<u8>>> { in incoming_body()
469 Stream { in incoming_body() enumerator
482 Inner::Stream { stream, body } => { in incoming_body()
493 let mut incoming = Incoming(Inner::Stream { stream, body }); in incoming_body()
498 Inner::Stream { stream, .. } => match stream.read(READ_SIZE) { in incoming_body()
511 let Inner::Stream { stream, body } = in incoming_body()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/ |
| H A D | futures_and_streams.rs | 51 Stream, enumerator
108 Stream(TypeStreamTableIndex), enumerator
115 TransmitIndex::Stream(_) => TransmitKind::Stream, in kind()
124 TransmitIndex::Stream(i) => { in payload()
1780 InterfaceType::Stream(src) => { in lift_index_to_stream()
1803 InterfaceType::Stream(dst) => { in lower_stream_to_index()
1830 InterfaceType::Stream(ty) => { in typecheck()
3280 (TransmitIndex::Stream(_), TransmitIndex::Stream(_)) => { in copy()
4133 TransmitIndex::Stream(_) => TransmitKind::Stream, in guest_drop_readable()
4443 TransmitIndex::Stream(src), in stream_transfer()
[all …]
|
| H A D | future_stream_any.rs | 225 InterfaceType::Stream(payload) => payload, in lower_to_index()
281 let InterfaceType::Stream(ty) = ty else { in lift_from_index()
318 InterfaceType::Stream(_) => Ok(()), in typecheck()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/ |
| H A D | values.rs | 94 Stream(StreamAny), enumerator
217 InterfaceType::Stream(_) => { in lift()
218 Val::Stream(StreamAny::linear_lift_from_flat(cx, ty, next(src))?) in lift()
499 (InterfaceType::Stream(_), Val::Stream(s)) => { in lower()
502 (InterfaceType::Stream(_), _) => unexpected(ty, self), in lower()
664 (InterfaceType::Stream(_), Val::Stream(s)) => s.linear_lower_to_memory(cx, ty, offset), in store()
665 (InterfaceType::Stream(_), _) => unexpected(ty, self), in store()
704 Val::Stream(_) => "stream", in desc()
788 (Self::Stream(l), Self::Stream(r)) => l == r, in eq()
789 (Self::Stream(_), _) => false, in eq()
[all …]
|
| H A D | types.rs | 157 (InterfaceType::Stream(t1), InterfaceType::Stream(t2)) => { in interface_types_equal()
160 (InterfaceType::Stream(_), _) => false, in interface_types_equal()
734 Stream(StreamType), enumerator
895 InterfaceType::Stream(index) => Type::Stream(instance.stream_type(*index)), in from()
928 Type::Stream(_) => "stream", in desc()
|
| H A D | concurrent.rs | 4086 TransmitIndex::Stream(ty), in stream_write()
4110 TransmitIndex::Stream(ty), in stream_read()
4145 TransmitIndex::Stream(ty), in flat_stream_write()
4174 TransmitIndex::Stream(ty), in flat_stream_read()
4193 instance.guest_drop_writable(self, TransmitIndex::Stream(ty), writer) in stream_drop_writable()
4637 Waitable::Stream | Waitable::Future => Self::Transmit(TableId::new(waitable)), in from_instance()
|
| /wasmtime-44.0.1/crates/misc/component-async-tests/src/ |
| H A D | util.rs | 1 use futures::{Sink, Stream, channel::oneshot};
30 impl<D, T: Send + Sync + Lower + 'static, S: Stream<Item = T> + Send + 'static> StreamProducer<D>
|
| /wasmtime-44.0.1/crates/c-api/src/component/types/ |
| H A D | val.rs | 32 Stream(Box<wasmtime_component_stream_type_t>), enumerator
64 Type::Stream(ty) => Self::Stream(Box::new(ty.into())), in from()
|
| /wasmtime-44.0.1/crates/wit-bindgen/src/ |
| H A D | rust.rs | 122 | TypeDefKind::Stream(_) in tyid()
182 TypeDefKind::Stream(ty) => { in tyid()
|
| H A D | types.rs | 163 TypeDefKind::Future(ty) | TypeDefKind::Stream(ty) => { in type_id_info()
|
| H A D | lib.rs | 211 .any(|(_, ty)| matches!(ty.kind, TypeDefKind::Future(_) | TypeDefKind::Stream(_))) in generate()
1633 TypeDefKind::Stream(t) => self.type_stream(id, name, t.as_ref(), &ty.docs), in define_type()
3414 | TypeDefKind::Stream(_) in type_contains_lists()
|
| /wasmtime-44.0.1/crates/environ/src/component/translate/ |
| H A D | inline.rs | 800 let InterfaceType::Stream(ty) = in initializer()
815 let InterfaceType::Stream(ty) = in initializer()
835 let InterfaceType::Stream(ty) = in initializer()
855 let InterfaceType::Stream(ty) = in initializer()
871 let InterfaceType::Stream(ty) = in initializer()
887 let InterfaceType::Stream(ty) = in initializer()
902 let InterfaceType::Stream(ty) = in initializer()
|
| /wasmtime-44.0.1/crates/misc/component-async-tests/tests/scenario/ |
| H A D | streams.rs | 8 FutureExt, Sink, SinkExt, Stream, StreamExt,
31 impl<D, S: Stream<Item = u8> + Send + 'static> StreamProducer<D> for DirectPipeProducer<S> {
|
| H A D | transmit.rs | 688 let Val::Stream(stream) = fields.next().unwrap() else { in from_result()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/wave/ |
| H A D | component.rs | 46 | Self::Stream(_) in kind()
143 | Self::Stream(_) in kind()
|
| /wasmtime-44.0.1/crates/environ/src/component/ |
| H A D | types_builder.rs | 463 ComponentDefinedType::Stream(ty) => { in defined_type()
464 InterfaceType::Stream(self.stream_table_type(types, ty)?) in defined_type()
861 | InterfaceType::Stream(_) in type_information()
|
| H A D | types.rs | 362 | InterfaceType::Stream(_) in canonical_abi()
608 Stream(TypeStreamTableIndex), enumerator
|
| /wasmtime-44.0.1/crates/wast/src/ |
| H A D | component.rs | 291 Val::Stream(..) => "stream", in mismatch()
|
| /wasmtime-44.0.1/crates/fuzzing/src/oracles/ |
| H A D | component_api.rs | 133 Type::Own(_) | Type::Borrow(_) | Type::Future(_) | Type::Stream(_) | Type::ErrorContext => { in arbitrary_val()
|
| /wasmtime-44.0.1/crates/c-api/src/component/ |
| H A D | val.rs | 360 Val::Stream(_) => todo!(), in from()
|
| /wasmtime-44.0.1/crates/wasi-http/src/p3/wit/deps/ |
| H A D | http.wit | 333 /// Stream returned by this method represents the contents of the body.
413 /// Stream returned by this method represents the contents of the body.
|
| /wasmtime-44.0.1/crates/environ/src/fact/ |
| H A D | trampoline.rs | 1173 | InterfaceType::Stream(_) in translate()
1212 InterfaceType::Stream(t) => self.translate_stream(*t, src, dst_ty, dst), in translate()
3607 InterfaceType::Stream(t) => *t, in translate_stream()
|
| /wasmtime-44.0.1/crates/debugger/wit/deps/ |
| H A D | filesystem.wit | 552 /// Stream operations which return `stream-error::last-operation-failed`
|
| /wasmtime-44.0.1/crates/wasi/src/p2/wit/deps/ |
| H A D | filesystem.wit | 552 /// Stream operations which return `stream-error::last-operation-failed`
|