chore: Use tokio in examples

Author: oblique

Cargo.toml

@@ -37,6 +37,7 @@ md5 = "0.7.0"
 rand = { version = "0.8.5", features = ["small_rng"] }
 structopt = "0.3.26"
 tempfile = "3.3.0"
+tokio = { version = "1", features = ["rt-multi-thread", "macros"] }
 
 # deps for tftpd-targz.rs
 async-compression = { version = "0.3.15", features = ["gzip", "futures-io"] }

README.md

@@ -33,21 +33,21 @@ Features:
 use async_tftp::server::TftpServerBuilder;
 use async_tftp::Result;
 
-fn main() -> Result<()> {
-    smol::block_on(async { // or any other runtime/executor
-        let tftpd = TftpServerBuilder::with_dir_ro(".")?.build().await?;
-        tftpd.serve().await?;
-        Ok(())
-    })
+#[tokio::main] // or any other runtime/executor
+async fn main() -> Result<()> {
+    let tftpd = TftpServerBuilder::with_dir_ro(".")?.build().await?;
+    tftpd.serve().await?;
+    Ok(())
 }
 ```
 
 Add in `Cargo.toml`:
 
 ```toml
 [dependencies]
-smol = "1" # or any other runtime/executor
 async-tftp = "0.3"
+# or any other runtime/executor
+tokio = { version = "1", features = ["rt-multi-thread", "macros"] }
 ```
 
 ## Running examples with cargo

examples/tftpd-dir.rs

@@ -1,7 +1,7 @@
 use anyhow::Result;
 use async_tftp::server::TftpServerBuilder;
-use futures_lite::future::block_on;
 
+#[tokio::main]
 fn main() -> Result<()> {
     fern::Dispatch::new()
         .level(log::LevelFilter::Info)
@@ -10,17 +10,15 @@ fn main() -> Result<()> {
         .apply()
         .expect("Failed to initialize logger");
 
-    block_on(async {
-        let tftpd = TftpServerBuilder::with_dir_ro(".")?
-            .bind("0.0.0.0:6969".parse().unwrap())
-            // Workaround to handle cases where client is behind VPN
-            .block_size_limit(1024)
-            .build()
-            .await?;
+    let tftpd = TftpServerBuilder::with_dir_ro(".")?
+        .bind("0.0.0.0:6969".parse().unwrap())
+        // Workaround to handle cases where client is behind VPN
+        .block_size_limit(1024)
+        .build()
+        .await?;
 
-        log::info!("Listening on: {}", tftpd.listen_addr()?);
-        tftpd.serve().await?;
+    log::info!("Listening on: {}", tftpd.listen_addr()?);
+    tftpd.serve().await?;
 
-        Ok(())
-    })
+    Ok(())
 }

src/lib.rs

@@ -27,21 +27,21 @@
 //! use async_tftp::server::TftpServerBuilder;
 //! use async_tftp::Result;
 //!
-//! fn main() -> Result<()> {
-//!     smol::block_on(async { // or any other runtime/executor
-//!         let tftpd = TftpServerBuilder::with_dir_ro(".")?.build().await?;
-//!         tftpd.serve().await?;
-//!         Ok(())
-//!     })
+//! #[tokio::main] // or any other runtime/executor
+//! async fn main() -> Result<()> {
+//!     let tftpd = TftpServerBuilder::with_dir_ro(".")?.build().await?;
+//!     tftpd.serve().await?;
+//!     Ok(())
 //! }
 //! ```
 //!
 //! Add in `Cargo.toml`:
 //!
 //! ```toml
 //! [dependencies]
-//! smol = "1" # or any other runtime/executor
 //! async-tftp = "0.3"
+//! # or any other runtime/executor
+//! tokio = { version = "1", features = ["rt-multi-thread", "macros"] }
 //! ```
 //!
 //! [smol]: https://docs.rs/smol