Searched refs:into_async_read (Results 1 – 6 of 6) sorted by relevance
47 stream::iter(vec![&b"12"[..], &b"\r"[..]]).map(Ok).into_async_read().interleave_pending(); in maybe_pending()54 .into_async_read() in maybe_pending()
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()
38 .into_async_read() in interleave_pending()
46 .into_async_read() in maybe_pending()
45 stream::iter(vec![&b"12"[..], &b"\n\n"[..]]).map(Ok).into_async_read().interleave_pending(); in maybe_pending()
147 mod into_async_read; module152 pub use self::into_async_read::IntoAsyncRead;1062 fn into_async_read(self) -> IntoAsyncRead<Self> in into_async_read() method