use tokio::main!

src/bastion/Cargo.toml

@@ -90,5 +90,5 @@ rand = "0.7.3"
 rayon = "1.3.1"
 num_cpus = "1.13.0"
 # hello_tokio example
-tokio = { version="1.1", features = ["time"] }
+tokio = { version="1.1", features = ["time", "macros"] }
 bastion-executor = { path = "../bastion-executor", features = ["runtime-tokio"] }

src/bastion/examples/hello_tokio.rs

@@ -1,3 +1,4 @@
+use anyhow::Result as AnyResult;
 use bastion::prelude::*;
 #[cfg(feature = "runtime-tokio")]
 use tokio;
@@ -18,7 +19,8 @@ use tracing::{error, info, warn, Level};
 /// Jan 31 11:54:24.473  WARN hello_tokio: the spawn! is complete
 /// Jan 31 11:54:34.372  WARN hello_tokio: we're done, stopping the bastion!
 #[cfg(feature = "runtime-tokio")]
-fn main() {
+#[tokio::main]
+async fn main() -> AnyResult<()> {
     // Initialize tracing logger
     // so we get nice output on the console.
     let subscriber = tracing_subscriber::fmt()
@@ -31,21 +33,30 @@ fn main() {
     let workers = Bastion::children(|children| {
         children.with_exec(|ctx: BastionContext| {
             async move {
+                warn!("just spawned!");
+                tokio::time::sleep(std::time::Duration::from_secs(1)).await;
+                warn!("Ok let's handle a message now.");
                 msg! {
                     ctx.recv().await?,
                     msg: &'static str => {
                         // Printing the incoming msg
                         error!("just received {}", msg);
 
+                        warn!("sleeping for 2 seconds without using the bastion executor");
+                        tokio::time::sleep(std::time::Duration::from_secs(2)).await;
+                        warn!("and done!");
+
                         // let's wait until a tokio powered future is complete
                         run!(blocking! {
+                            warn!("let's sleep for 5 seconds within a blocking block");
                             tokio::time::sleep(std::time::Duration::from_secs(5)).await;
                             warn!("awaited 5 seconds");
                         });
                         error!("waited for the blocking! to be complete!");
 
                         // let's spawn a tokio powered future and move on
                         spawn! {
+                            warn!("let's sleep for 10 seconds within a spawn block");
                             tokio::time::sleep(std::time::Duration::from_secs(10)).await;
                             warn!("the spawn! is complete");
                         };
@@ -75,6 +86,7 @@ fn main() {
 
     // We are done, stopping the bastion!
     Bastion::stop();
+    Ok(())
 }
 
 #[cfg(not(feature = "runtime-tokio"))]