Searched refs:into_future (Results 1 – 7 of 7) sorted by relevance
26 mod into_future; module104 pub use self::into_future::IntoFuture;604 fn into_future(self) -> IntoFuture<Self> in into_future() method
94 mod into_future; module96 pub use self::into_future::StreamFuture;271 fn into_future(self) -> StreamFuture<Self> in into_future() method
60 Poll::Ready(Some(fut)) => this.in_progress_queue.push(fut.into_future()), in poll_next()
57 Poll::Ready(Some(fut)) => this.in_progress_queue.push(fut.into_future()), in poll_next()
65 self.inner.push(stream.into_future()); in push()
349 assert_eq!(Ok(Some(())), block_on(Some(ok::<(), ()>(())).into_future())); in option()350 assert_eq!(Ok::<_, ()>(None::<()>), block_on(None::<FutureResult<(), ()>>.into_future())); in option()
526 .into_future(); in run_worker()