Searched refs:into_async_read (Results 1 – 12 of 12) sorted by relevance
50 let mut reader = stream.interleave_pending().into_async_read(); in test_into_async_read()77 let mut reader = stream.interleave_pending().into_async_read(); in test_into_async_bufread()
65 stream::iter(vec![&b"12"[..], &b"\r"[..]]).map(Ok).into_async_read().interleave_pending(); in maybe_pending()72 .into_async_read() in maybe_pending()
38 .into_async_read() in interleave_pending()
46 .into_async_read() in maybe_pending()
88 stream::iter(vec![&b"12"[..], &b"\n\n"[..]]).map(Ok).into_async_read().interleave_pending(); in maybe_pending()
162 mod into_async_read; module167 pub use self::into_async_read::IntoAsyncRead;1186 fn into_async_read(self) -> IntoAsyncRead<Self> in into_async_read() method
1 …nal/rust/android-crates-io/crates/futures-util/src/stream/try_stream/into_async_read.rs external/r…3 …nal/rust/android-crates-io/crates/futures-util/src/stream/try_stream/into_async_read.rs external/r…104 external/rust/android-crates-io/crates/futures-util/src/stream/try_stream/into_async_read.rs:
1 …nal/rust/android-crates-io/crates/futures-util/src/stream/try_stream/into_async_read.rs external/r…