Move FutureObj from futures-core to futures-task

futures-core/src/future/mod.rs → futures-core/src/future.rs

@@ -6,9 +6,6 @@ use core::task::{Context, Poll};
 
 pub use core::future::Future;
 
-mod future_obj;
-pub use self::future_obj::{FutureObj, LocalFutureObj, UnsafeFutureObj};
-
 /// An owned dynamically typed [`Future`] for use in cases where you can't
 /// statically type your result or need to add some indirection.
 #[cfg(feature = "alloc")]

futures-executor/src/local_pool.rs

@@ -1,9 +1,9 @@
 use crate::enter;
-use futures_core::future::{Future, FutureObj, LocalFutureObj};
-use futures_core::stream::{Stream};
+use futures_core::future::Future;
+use futures_core::stream::Stream;
 use futures_core::task::{Context, Poll};
-use futures_task::{Spawn, LocalSpawn, SpawnError};
-use futures_util::task::{waker_ref, ArcWake};
+use futures_task::{FutureObj, LocalFutureObj, Spawn, LocalSpawn, SpawnError};
+use futures_task::{waker_ref, ArcWake};
 use futures_util::stream::FuturesUnordered;
 use futures_util::stream::StreamExt;
 use futures_util::pin_mut;

futures-executor/src/thread_pool.rs

@@ -1,10 +1,10 @@
 use crate::enter;
 use crate::unpark_mutex::UnparkMutex;
-use futures_core::future::{Future, FutureObj};
+use futures_core::future::Future;
 use futures_core::task::{Context, Poll};
-use futures_task::{Spawn, SpawnError};
+use futures_task::{FutureObj, Spawn, SpawnError};
+use futures_task::{ArcWake, waker_ref};
 use futures_util::future::FutureExt;
-use futures_util::task::{ArcWake, waker_ref};
 use std::cmp;
 use std::fmt;
 use std::io;

futures-task/src/lib.rs

@@ -51,10 +51,12 @@ cfg_target_has_atomic! {
     pub use crate::waker_ref::{waker_ref, WakerRef};
 }
 
+mod future_obj;
+pub use crate::future_obj::{FutureObj, LocalFutureObj, UnsafeFutureObj};
+
 mod noop_waker;
 pub use crate::noop_waker::noop_waker;
 #[cfg(feature = "std")]
 pub use crate::noop_waker::noop_waker_ref;
 
-pub use futures_core::future::{FutureObj, LocalFutureObj};
 pub use futures_core::task::{Context, Poll, Waker, RawWaker, RawWakerVTable};

futures-task/src/spawn.rs

@@ -1,5 +1,5 @@
+use crate::{FutureObj, LocalFutureObj};
 use core::fmt;
-use futures_core::future::{FutureObj, LocalFutureObj};
 
 /// The `Spawn` trait allows for pushing futures onto an executor that will
 /// run them to completion.

futures-test/src/task/noop_spawner.rs

@@ -1,5 +1,4 @@
-use futures_core::future::FutureObj;
-use futures_task::{Spawn, SpawnError};
+use futures_task::{Spawn, SpawnError, FutureObj};
 
 /// An implementation of [`Spawn`](futures_core::task::Spawn) that
 /// discards spawned futures when used.

futures-test/src/task/panic_spawner.rs

@@ -1,5 +1,4 @@
-use futures_core::future::FutureObj;
-use futures_task::{Spawn, SpawnError};
+use futures_task::{Spawn, SpawnError, FutureObj};
 
 /// An implementation of [`Spawn`](futures_core::task::Spawn) that panics
 /// when used.

futures-test/src/task/record_spawner.rs

@@ -1,5 +1,4 @@
-use futures_core::future::FutureObj;
-use futures_task::{Spawn, SpawnError};
+use futures_task::{Spawn, SpawnError, FutureObj};
 
 /// An implementation of [`Spawn`](futures_core::task::Spawn) that records
 /// any [`Future`](futures_core::future::Future)s spawned on it.

futures-util/src/compat/executor.rs

@@ -6,8 +6,7 @@ use crate::{
 };
 use futures_01::Future as Future01;
 use futures_01::future::{Executor as Executor01, ExecuteError as ExecuteError01};
-use futures_core::future::FutureObj;
-use futures_task::{Spawn as Spawn03, SpawnError as SpawnError03};
+use futures_task::{FutureObj, Spawn as Spawn03, SpawnError as SpawnError03};
 
 /// A future that can run on a futures 0.1
 /// [`Executor`](futures_01::future::Executor).

futures-util/src/future/mod.rs

@@ -7,6 +7,7 @@
 #[cfg(feature = "alloc")]
 pub use futures_core::future::{BoxFuture, LocalBoxFuture};
 pub use futures_core::future::{FusedFuture, Future, TryFuture};
+pub use futures_task::{FutureObj, LocalFutureObj, UnsafeFutureObj};
 
 // Extension traits and combinators
 

futures-util/src/stream/futures_unordered/mod.rs

@@ -3,11 +3,10 @@
 //! This module is only available when the `std` or `alloc` feature of this
 //! library is activated, and it is activated by default.
 
-use crate::task::{AtomicWaker};
-use futures_core::future::{Future, FutureObj, LocalFutureObj};
+use futures_core::future::Future;
 use futures_core::stream::{FusedStream, Stream};
 use futures_core::task::{Context, Poll};
-use futures_task::{Spawn, LocalSpawn, SpawnError};
+use futures_task::{FutureObj, LocalFutureObj, AtomicWaker, Spawn, LocalSpawn, SpawnError};
 use core::cell::UnsafeCell;
 use core::fmt::{self, Debug};
 use core::iter::FromIterator;

futures-util/src/task/mod.rs

@@ -18,7 +18,10 @@ pub use self::spawn::{SpawnExt, LocalSpawnExt};
 
 pub use futures_core::task::{Context, Poll, Waker, RawWaker, RawWakerVTable};
 
-pub use futures_task::{Spawn, LocalSpawn, SpawnError};
+pub use futures_task::{
+    Spawn, LocalSpawn, SpawnError,
+    FutureObj, LocalFutureObj, UnsafeFutureObj,
+};
 
 pub use futures_task::noop_waker;
 #[cfg(feature = "std")]

futures-util/src/task/spawn.rs

@@ -6,9 +6,9 @@ use futures_task::{LocalSpawn, Spawn};
 #[cfg(feature = "std")]
 use crate::future::{FutureExt, RemoteHandle};
 #[cfg(feature = "alloc")]
-use futures_core::future::{Future, FutureObj, LocalFutureObj};
+use futures_core::future::Future;
 #[cfg(feature = "alloc")]
-use futures_task::SpawnError;
+use futures_task::{SpawnError, FutureObj, LocalFutureObj};
 #[cfg(feature = "alloc")]
 use alloc::boxed::Box;
 

futures/src/lib.rs

@@ -184,12 +184,13 @@ pub mod future {
 
     pub use futures_core::future::{
         Future, TryFuture, FusedFuture,
-        FutureObj, LocalFutureObj, UnsafeFutureObj,
     };
 
     #[cfg(feature = "alloc")]
     pub use futures_core::future::{BoxFuture, LocalBoxFuture};
 
+    pub use futures_task::{FutureObj, LocalFutureObj, UnsafeFutureObj};
+
     pub use futures_util::future::{
         lazy, Lazy,
         maybe_done, MaybeDone,
@@ -447,7 +448,10 @@ pub mod task {
 
     pub use futures_core::task::{Context, Poll, Waker, RawWaker, RawWakerVTable};
 
-    pub use futures_task::{Spawn, LocalSpawn, SpawnError};
+    pub use futures_task::{
+        Spawn, LocalSpawn, SpawnError,
+        FutureObj, LocalFutureObj, UnsafeFutureObj,
+    };
 
     pub use futures_util::task::noop_waker;