remove spawn from top-level

benches/common/mod.rs

@@ -30,7 +30,7 @@ macro_rules! benchmark_suite {
 
             let tasks = (0..300)
                 .map(|_| {
-                    runtime::spawn(async {
+                    runtime::task::spawn(async {
                         Task { depth: 0 }.await;
                     })
                 })
@@ -44,7 +44,7 @@ macro_rules! benchmark_suite {
         #[runtime::bench($rt)]
         async fn spawn_many() {
             let tasks = (0..25_000)
-                .map(|_| runtime::spawn(async {}))
+                .map(|_| runtime::task::spawn(async {}))
                 .collect::<Vec<_>>();
 
             for task in tasks {
@@ -61,15 +61,15 @@ macro_rules! benchmark_suite {
 
             let tasks = (0..300)
                 .map(|_| {
-                    runtime::spawn(async {
+                    runtime::task::spawn(async {
                         let (r, s) = mio::Registration::new2();
                         let registration = Registration::new();
                         registration.register(&r).unwrap();
 
                         let mut depth = 0;
                         let mut capture = Some(r);
 
-                        runtime::spawn(
+                        runtime::task::spawn(
                             Compat01As03::new(future::poll_fn(move || loop {
                                 if registration.poll_read_ready().unwrap().is_ready() {
                                     depth += 1;

examples/guessing.rs

@@ -65,7 +65,7 @@ async fn main() -> Result<(), failure::Error> {
     incoming
         .try_for_each_concurrent(None, |stream| {
             async move {
-                runtime::spawn(play(stream)).await?;
+                runtime::task::spawn(play(stream)).await?;
                 Ok::<(), failure::Error>(())
             }
         })

examples/tcp-echo.rs

@@ -18,7 +18,7 @@ async fn main() -> std::io::Result<()> {
         .incoming()
         .try_for_each_concurrent(None, |stream| {
             async move {
-                runtime::spawn(async move {
+                runtime::task::spawn(async move {
                     println!("Accepting from: {}", stream.peer_addr()?);
 
                     let (reader, writer) = &mut stream.split();

examples/tcp-proxy.rs

@@ -16,7 +16,7 @@ async fn main() -> std::io::Result<()> {
         .incoming()
         .try_for_each_concurrent(None, |client| {
             async move {
-                runtime::spawn(async move {
+                runtime::task::spawn(async move {
                     let server = TcpStream::connect("127.0.0.1:8080").await?;
                     println!(
                         "Proxying {} to {}",

runtime-attributes/src/lib.rs

@@ -140,7 +140,7 @@ pub fn test(attr: TokenStream, item: TokenStream) -> TokenStream {
 ///
 /// #[runtime::test]
 /// async fn spawn_and_await() {
-///   runtime::spawn(async {}).await;
+///   runtime::task::spawn(async {}).await;
 /// }
 /// ```
 #[proc_macro_attribute]

src/lib.rs

@@ -120,9 +120,6 @@ pub mod prelude {
     pub use super::time::StreamExt as _;
 }
 
-#[doc(inline)]
-pub use task::spawn;
-
 #[doc(inline)]
 pub use runtime_attributes::{bench, test};
 

src/net/tcp.rs

@@ -304,7 +304,7 @@ impl fmt::Debug for ConnectFuture {
 ///     // accept connections and process them in parallel
 ///     let mut incoming = listener.incoming();
 ///     while let Some(stream) = incoming.next().await {
-///         runtime::spawn(async move {
+///         runtime::task::spawn(async move {
 ///             let stream = stream?;
 ///             println!("Accepting from: {}", stream.peer_addr()?);
 ///

src/task.rs

@@ -56,7 +56,7 @@ impl<'a> Spawn for &'a Spawner {
 ///
 /// #[runtime::main]
 /// async fn main() {
-///     let handle = runtime::spawn(async {
+///     let handle = runtime::task::spawn(async {
 ///         println!("running the future");
 ///         42
 ///     });

tests/native.rs

@@ -4,7 +4,7 @@ use runtime_native::Native;
 
 #[runtime::test(Native)]
 async fn spawn() {
-    let handle = runtime::spawn(async {
+    let handle = runtime::task::spawn(async {
         println!("hello planet from Native");
         42
     });

tests/tokio-current-thread.rs

@@ -2,7 +2,7 @@
 
 #[runtime::test(runtime_tokio::TokioCurrentThread)]
 async fn spawn() {
-    let handle = runtime::spawn(async {
+    let handle = runtime::task::spawn(async {
         println!("hello planet from Tokio current-thread");
         42
     });

tests/tokio.rs

@@ -4,7 +4,7 @@ use runtime_tokio::Tokio;
 
 #[runtime::test(Tokio)]
 async fn spawn() {
-    let handle = runtime::spawn(async {
+    let handle = runtime::task::spawn(async {
         println!("hello planet from Tokio");
         42
     });