Searched refs:AsyncStream (Results 1 – 8 of 8) sorted by relevance
| /external/rust/crates/async-stream/src/ |
| D | async_stream.rs | 12 pub struct AsyncStream<T, U> {
20 impl<T, U> AsyncStream<T, U> { implementation
22 pub fn new(rx: Receiver<T>, generator: U) -> AsyncStream<T, U> { in new()
23 AsyncStream { in new()
31 impl<T, U> FusedStream for AsyncStream<T, U> implementation
40 impl<T, U> Stream for AsyncStream<T, U> implementation
|
| D | lib.rs | 236 pub use crate::async_stream::AsyncStream;
|
| /external/crosvm/common/audio_streams/src/ |
| D | async_api.rs | 61 pub type AsyncStream = Box<dyn ReadWriteAsync + Send>; typedef
68 fn async_unix_stream(&self, f: UnixStream) -> Result<AsyncStream>; in async_unix_stream() argument
99 fn async_unix_stream(&self, _f: UnixStream) -> Result<AsyncStream> { in async_unix_stream() argument
|
| D | audio_streams.rs | 60 pub use async_api::AsyncStream;
|
| /external/crosvm/cros_async/src/ |
| D | audio_streams_async.rs | 18 use audio_streams::async_api::AsyncStream;
86 fn async_unix_stream(&self, stream: UnixStream) -> Result<AsyncStream> { in async_unix_stream() argument
|
| /external/rust/crates/async-stream/ |
| D | CHANGELOG.md | 18 * Implement `Stream::size_hint` method on `AsyncStream` (#40)
|
| /external/rust/crates/async-stream-impl/src/ |
| D | lib.rs | 232 #crate_path::__private::AsyncStream::new(__yield_rx, async move { in stream_inner()
266 #crate_path::__private::AsyncStream::new(__yield_rx, async move { in try_stream_inner()
|
| /external/pigweed/pw_stream/ |
| D | docs.rst | 655 capabilities, or a separate ``AsyncStream`` could be created.
|