19 #[cfg(feature = "io-compat")]
20 #[cfg_attr(docsrs, doc(cfg(feature = "io-compat")))]
26 // Re-export some types from `std::io` so that users don't have to deal
31 #[cfg(feature = "read-initializer")]
32 #[cfg_attr(docsrs, doc(cfg(feature = "read-initializer")))]
38 // https://github.com/rust-lang/rust/blob/master/src/libstd/sys_common/io.rs#L1
43 /// A buffer is always initialized if `read-initializer` feature is disabled.
46     #[cfg(feature = "read-initializer")]  in initialize()
146 #[cfg(feature = "write-all-vectored")]
148 #[cfg(feature = "write-all-vectored")]
162     /// # futures::executor::block_on(async {
176     fn chain<R>(self, next: R) -> Chain<Self, R>  in chain()
193     /// # futures::executor::block_on(async {
208     fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> Read<'a, Self>  in read()
219     fn read_vectored<'a>(&'a mut self, bufs: &'a mut [IoSliceMut<'a>]) -> ReadVectored<'a, Self>  in read_vectored()
236     /// # futures::executor::block_on(async {
251     /// # futures::executor::block_on(async {
265     ) -> ReadExact<'a, Self>  in read_exact()
278     /// # futures::executor::block_on(async {
293     ) -> ReadToEnd<'a, Self>  in read_to_end()
306     /// # futures::executor::block_on(async {
321     ) -> ReadToString<'a, Self>  in read_to_string()
335     /// # futures::executor::block_on(async {
356     fn split(self) -> (ReadHalf<Self>, WriteHalf<Self>)  in split()
369     /// # futures::executor::block_on(async {
382     fn take(self, limit: u64) -> Take<Self>  in take()
389     /// used as a futures 0.1 / tokio-io 0.1 `AsyncRead`. If the wrapped type
393     /// Requires the `io-compat` feature to enable.
394     #[cfg(feature = "io-compat")]
395     #[cfg_attr(docsrs, doc(cfg(feature = "io-compat")))]
396     fn compat(self) -> Compat<Self>  in compat()
412     /// # futures::executor::block_on(async {
429     fn flush(&mut self) -> Flush<'_, Self>  in flush()
436     fn close(&mut self) -> Close<'_, Self>  in close()
446     fn write<'a>(&'a mut self, buf: &'a [u8]) -> Write<'a, Self>  in write()
457     fn write_vectored<'a>(&'a mut self, bufs: &'a [IoSlice<'a>]) -> WriteVectored<'a, Self>  in write_vectored()
473     /// # futures::executor::block_on(async {
483     fn write_all<'a>(&'a mut self, buf: &'a [u8]) -> WriteAll<'a, Self>  in write_all()
515     /// # futures::executor::block_on(async {
533     #[cfg(feature = "write-all-vectored")]
537     ) -> WriteAllVectored<'a, Self>  in write_all_vectored()
545     /// used as a futures 0.1 / tokio-io 0.1 `AsyncWrite`.
546     /// Requires the `io-compat` feature to enable.
547     #[cfg(feature = "io-compat")]
548     #[cfg_attr(docsrs, doc(cfg(feature = "io-compat")))]
549     fn compat_write(self) -> Compat<Self>  in compat_write()
566     /// # futures::executor::block_on(async {
583     fn into_sink<Item: AsRef<[u8]>>(self) -> IntoSink<Self, Item>  in into_sink()
599     fn seek(&mut self, pos: SeekFrom) -> Seek<'_, Self>  in seek()
610     /// Creates a future which will wait for a non-empty buffer to be available from this I/O
615     /// ```rust
616     /// # futures::executor::block_on(async {
633     fn fill_buf(&mut self) -> FillBuf<'_, Self>  in fill_buf()
641     /// ```rust
642     /// # futures::executor::block_on(async {
679     /// # futures::executor::block_on(async {
682     /// let mut cursor = Cursor::new(b"lorem-ipsum");
686     /// let num_bytes = cursor.read_until(b'-', &mut buf).await?;
688     /// assert_eq!(buf, b"lorem-");
692     /// let num_bytes = cursor.read_until(b'-', &mut buf).await?;
698     /// let num_bytes = cursor.read_until(b'-', &mut buf).await?;
707     ) -> ReadUntil<'a, Self>  in read_until()
731     /// also return an error if the read bytes are not valid UTF-8. If an I/O
733     /// the event that all data read so far was valid UTF-8.
740     /// # futures::executor::block_on(async {
764     fn read_line<'a>(&'a mut self, buf: &'a mut String) -> ReadLine<'a, Self>  in read_line()
789     /// # futures::executor::block_on(async {
802     fn lines(self) -> Lines<Self>  in lines()
813 pub(crate) fn assert_read<R>(reader: R) -> R  in assert_read()
821 pub(crate) fn assert_write<W>(writer: W) -> W  in assert_write()