| /wasmtime-44.0.1/crates/wasi-tls/src/p3/util/ |
| H A D | closed.rs | 8 use wasmtime::component::{Destination, Source, StreamConsumer, StreamProducer, StreamResult};
53 impl<D> StreamConsumer<D> for Closed {
|
| H A D | tokio_streams.rs | 8 use wasmtime::component::{Destination, Source, StreamConsumer, StreamProducer, StreamResult};
111 impl<D, IO> StreamConsumer<D> for AsyncWriteConsumer<IO>
|
| /wasmtime-44.0.1/crates/misc/component-async-tests/src/ |
| H A D | util.rs | 11 Destination, FutureConsumer, FutureProducer, Lift, Lower, Source, StreamConsumer,
73 StreamConsumer<D> for PipeConsumer<T, S>
|
| /wasmtime-44.0.1/crates/misc/component-async-tests/tests/scenario/ |
| H A D | streams.rs | 22 Destination, FutureReader, Lift, Linker, ResourceTable, Source, StreamConsumer,
67 impl<D, S: Sink<u8, Error: std::error::Error + Send + Sync> + Send + 'static> StreamConsumer<D>
355 impl<D, T: Lift + 'static> StreamConsumer<D> for OneAtATime<T> {
|
| H A D | transmit.rs | 17 Instance, Linker, ResourceTable, Source, StreamConsumer, StreamProducer, StreamReader,
57 impl<D> StreamConsumer<D> for BufferStreamConsumer {
153 impl<D, C: StreamConsumer<D>> StreamConsumer<D> for DelayedStreamConsumer<C> {
254 impl<D, C: StreamConsumer<D>> StreamConsumer<D> for ProcrastinatingStreamConsumer<C> {
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/ |
| H A D | mod.rs | 124 GuardedStreamReader, JoinHandle, ReadBuffer, Source, StreamAny, StreamConsumer, StreamProducer,
|
| H A D | concurrent.rs | 100 FutureReader, GuardedFutureReader, GuardedStreamReader, ReadBuffer, Source, StreamConsumer,
|
| /wasmtime-44.0.1/crates/wasi/src/p3/cli/ |
| H A D | host.rs | 17 Access, Destination, FutureReader, Resource, Source, StreamConsumer, StreamProducer,
89 impl<D> StreamConsumer<D> for OutputStreamConsumer {
|
| /wasmtime-44.0.1/crates/wasi-http/src/p3/ |
| H A D | body.rs | 17 Access, Destination, FutureConsumer, FutureReader, Resource, Source, StreamConsumer,
170 impl<D> StreamConsumer<D> for LimitedGuestBodyConsumer {
228 impl<D> StreamConsumer<D> for UnlimitedGuestBodyConsumer {
|
| /wasmtime-44.0.1/crates/wasi/src/p3/sockets/host/types/ |
| H A D | tcp.rs | 20 Access, Accessor, Destination, FutureReader, Resource, ResourceTable, Source, StreamConsumer,
190 impl<D> StreamConsumer<D> for SendStreamConsumer {
|
| /wasmtime-44.0.1/crates/wasi/src/p3/filesystem/ |
| H A D | host.rs | 21 Access, Accessor, Destination, FutureReader, Resource, ResourceTable, Source, StreamConsumer,
429 impl<D> StreamConsumer<D> for WriteStreamConsumer {
|
| /wasmtime-44.0.1/crates/fuzzing/src/oracles/ |
| H A D | component_async.rs | 17 FutureReader, HasSelf, Linker, ResourceTable, Source, StreamConsumer, StreamProducer,
961 impl StreamConsumer<Data> for HostStreamConsumer {
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/ |
| H A D | futures_and_streams.rs | 990 pub trait StreamConsumer<D>: Send + 'static { interface
1260 impl<D: 'static, T: func::Lift + 'static, C: FutureConsumer<D, Item = T>> StreamConsumer<D> in pipe()
1678 consumer: impl StreamConsumer<S::Data, Item = T>, in pipe()
2703 fn set_consumer<C: StreamConsumer<T>>( in set_consumer()
|