change example to use tokio::spawn again

jgraef · Jul 9, 2024 · 3e75043 · 3e75043
1 parent 2b0a64f
commit 3e75043
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -41,7 +41,7 @@ web-sys = { version = "0.3", features = ["WebSocket", "CloseEvent", "ErrorEvent"
 wasm-bindgen-futures = "0.4"
 
 [dev-dependencies]
-tokio = { version = "1", features = ["macros", "rt"] }
+tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
 reqwest = { version = "0.12", features = ["default-tls"] }
 serde = { version = "1.0", features = ["derive"] }
 

diff --git a/examples/hello_world.rs b/examples/hello_world.rs
@@ -2,7 +2,7 @@ use futures_util::{SinkExt, StreamExt, TryStreamExt};
 use reqwest::Client;
 use reqwest_websocket::{Error, Message, RequestBuilderExt};
 
-#[tokio::main(flavor = "current_thread")]
+#[tokio::main]
 async fn main() -> Result<(), Error> {
     let websocket = Client::default()
         .get("wss://echo.websocket.org/")
@@ -14,7 +14,7 @@ async fn main() -> Result<(), Error> {
 
     let (mut tx, mut rx) = websocket.split();
 
-    tokio::task::spawn_local(async move {
+    tokio::spawn(async move {
         for i in 1..11 {
             tx.send(Message::Text(format!("Hello, World! #{i}")))
                 .await