1 use futures_01::executor::{
17 #[cfg(feature = "io-compat")]
18 #[cfg_attr(docsrs, doc(cfg(feature = "io-compat")))]
19 #[allow(unreachable_pub)] // https://github.com/rust-lang/rust/issues/57411
23 /// object to a futures 0.3-compatible version,
34     /// object in a futures 0.3-compatible wrapper.
35     pub fn new(object: T) -> Self {  in new()
41     fn in_notify<R>(&mut self, cx: &mut Context<'_>, f: impl FnOnce(&mut T) -> R) -> R {  in in_notify()
47     pub fn get_ref(&self) -> &T {  in get_ref()
53     pub fn get_mut(&mut self) -> &mut T {  in get_mut()
59     pub fn into_inner(self) -> T {  in into_inner()
72     /// # futures::executor::block_on(async {
81     fn compat(self) -> Compat01As03<Self>  in compat()
98     /// # futures::executor::block_on(async {
108     fn compat(self) -> Compat01As03<Self>  in compat()
127     /// # futures::executor::block_on(async {
140     fn sink_compat(self) -> Compat01As03Sink<Self, Self::SinkItem>  in sink_compat()
150 fn poll_01_to_03<T, E>(x: Result<Async01<T>, E>) -> task03::Poll<Result<T, E>> {  in poll_01_to_03()
163     ) -> task03::Poll<Self::Output> {  in poll()
174     ) -> task03::Poll<Option<Self::Item>> {  in poll_next()
183 /// Converts a futures 0.1 Sink object to a futures 0.3-compatible version
199     /// Wraps a futures 0.1 Sink object in a futures 0.3-compatible wrapper.
200     pub fn new(inner: S) -> Self {  in new()
211         f: impl FnOnce(&mut S) -> R,  in in_notify()
212     ) -> R {  in in_notify()
218     pub fn get_ref(&self) -> &S {  in get_ref()
223     pub fn get_mut(&mut self) -> &mut S {  in get_mut()
228     pub fn into_inner(self) -> S {  in into_inner()
243     ) -> task03::Poll<Option<Self::Item>> {  in poll_next()
262     ) -> Result<(), Self::Error> {  in start_send()
271     ) -> task03::Poll<Result<(), Self::Error>> {  in poll_ready()
287     ) -> task03::Poll<Result<(), Self::Error>> {  in poll_flush()
309     ) -> task03::Poll<Result<(), Self::Error>> {  in poll_close()
347     fn from(handle: WakerToHandle<'_>) -> Self {  in from()
361     unsafe fn clone_raw(&self) -> NotifyHandle01 {  in clone_raw()
371 #[cfg(feature = "io-compat")]
372 #[cfg_attr(docsrs, doc(cfg(feature = "io-compat")))]
375     #[cfg(feature = "read-initializer")]
381     /// Extension trait for tokio-io [`AsyncRead`](tokio_io::AsyncRead)
382     #[cfg_attr(docsrs, doc(cfg(feature = "io-compat")))]
384         /// Converts a tokio-io [`AsyncRead`](tokio_io::AsyncRead) into a futures-io 0.3
388         /// # futures::executor::block_on(async {
401         fn compat(self) -> Compat01As03<Self>  in compat()
410     /// Extension trait for tokio-io [`AsyncWrite`](tokio_io::AsyncWrite)
411     #[cfg_attr(docsrs, doc(cfg(feature = "io-compat")))]
413         /// Converts a tokio-io [`AsyncWrite`](tokio_io::AsyncWrite) into a futures-io 0.3
417         /// # futures::executor::block_on(async {
430         fn compat(self) -> Compat01As03<Self>  in compat()
440         #[cfg(feature = "read-initializer")]
441         unsafe fn initializer(&self) -> Initializer {  in initializer()
451             -> task03::Poll<Result<usize, Error>>  in poll_read()
459             -> task03::Poll<Result<usize, Error>>  in poll_write()
465             -> task03::Poll<Result<(), Error>>  in poll_flush()
471             -> task03::Poll<Result<(), Error>>  in poll_close()