| /wasmtime-44.0.1/crates/wasi-tls/src/p3/util/ |
| H A D | closed.rs | 8 use wasmtime::component::{Destination, Source, StreamConsumer, StreamProducer, StreamResult};
39 impl<D> StreamProducer<D> for Closed {
|
| H A D | tokio_streams.rs | 8 use wasmtime::component::{Destination, Source, StreamConsumer, StreamProducer, StreamResult};
35 impl<D, IO> StreamProducer<D> for AsyncReadProducer<IO>
|
| /wasmtime-44.0.1/crates/wasi/src/p3/ |
| H A D | mod.rs | 24 use wasmtime::component::{Destination, Linker, StreamProducer, StreamResult, VecBuffer};
43 impl<I, T, E, D> StreamProducer<D> for FallibleIteratorProducer<I, E>
|
| /wasmtime-44.0.1/crates/misc/component-async-tests/src/ |
| H A D | util.rs | 12 StreamProducer, StreamResult,
30 impl<D, T: Send + Sync + Lower + 'static, S: Stream<Item = T> + Send + 'static> StreamProducer<D>
|
| /wasmtime-44.0.1/crates/misc/component-async-tests/tests/scenario/ |
| H A D | streams.rs | 23 StreamProducer, StreamReader, StreamResult, VecBuffer,
31 impl<D, S: Stream<Item = u8> + Send + 'static> StreamProducer<D> for DirectPipeProducer<S> {
317 impl<D, T: Lift + Unpin + 'static> StreamProducer<D> for VecProducer<T> {
|
| H A D | transmit.rs | 17 Instance, Linker, ResourceTable, Source, StreamConsumer, StreamProducer, StreamReader,
27 impl<D> StreamProducer<D> for BufferStreamProducer {
125 impl<D, P: StreamProducer<D>> StreamProducer<D> for DelayedStreamProducer<P> {
230 impl<D, P: StreamProducer<D>> StreamProducer<D> for ProcrastinatingStreamProducer<P> {
|
| /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 | 101 StreamProducer, StreamReader, StreamResult, VecBuffer, WriteBuffer,
|
| /wasmtime-44.0.1/crates/wasi/src/p3/cli/ |
| H A D | host.rs | 17 Access, Destination, FutureReader, Resource, Source, StreamConsumer, StreamProducer,
37 impl<D> StreamProducer<D> for InputStreamProducer {
|
| /wasmtime-44.0.1/crates/wasi/src/p3/sockets/host/types/ |
| H A D | tcp.rs | 21 StreamProducer, StreamReader, StreamResult,
53 impl<D> StreamProducer<D> for ListenStreamProducer<D>
116 impl<D> StreamProducer<D> for ReceiveStreamProducer {
|
| /wasmtime-44.0.1/crates/wasi/src/p3/filesystem/ |
| H A D | host.rs | 22 StreamProducer, StreamReader, StreamResult,
161 impl<D> StreamProducer<D> for ReadStreamProducer {
305 impl<D> StreamProducer<D> for ReadDirStream {
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/ |
| H A D | futures_and_streams.rs | 501 pub trait StreamProducer<D>: Send + 'static { interface
661 impl<T, D> StreamProducer<D> for iter::Empty<T>
679 impl<T, D> StreamProducer<D> for stream::Empty<T>
697 impl<T, D> StreamProducer<D> for Vec<T>
716 impl<T, D> StreamProducer<D> for Box<[T]>
736 impl<D> StreamProducer<D> for bytes::Bytes {
753 impl<D> StreamProducer<D> for bytes::BytesMut {
1188 impl<D, T: func::Lower + 'static, P: FutureProducer<D, Item = T>> StreamProducer<D> in new()
1601 producer: impl StreamProducer<S::Data, Item = T>, in new()
2522 fn new_transmit<P: StreamProducer<T>>( in new_transmit()
|
| /wasmtime-44.0.1/crates/wasi-http/src/p3/ |
| H A D | body.rs | 18 StreamProducer, StreamReader, StreamResult,
464 impl<D> StreamProducer<D> for HostBodyStreamProducer<D>
|
| /wasmtime-44.0.1/crates/fuzzing/src/oracles/ |
| H A D | component_async.rs | 17 FutureReader, HasSelf, Linker, ResourceTable, Source, StreamConsumer, StreamProducer,
1061 impl StreamProducer<Data> for HostStreamProducer {
1217 impl StreamProducer<Data> for SharedStream {
|
| /wasmtime-44.0.1/tests/all/component_model/ |
| H A D | async.rs | 1159 impl StreamProducer<()> for NeverWriteStreamProducer { in stream_cancel_read_async_does_not_corrupt_state()
|