fix: spawn generators to remove time skew (#272)

* chore: clean out unnecessary `device_id` * style: spawn to improve readability * fix: print send errors * fix: `ActionResponse` against uplink
bytebeamio · Aug 22, 2023 · 67dff9f · 67dff9f
1 parent b654caa
commit 67dff9f
Show file tree

Hide file tree

Showing 4 changed files with 462 additions and 539 deletions.
diff --git a/tools/simulator/Cargo.lock b/tools/simulator/Cargo.lock
diff --git a/tools/simulator/Cargo.toml b/tools/simulator/Cargo.toml
@@ -6,6 +6,7 @@ authors = ["Devdutt Shenoi <[email protected]>"]
 
 [dependencies]
 fake = { version = "2.5.0", features = ["derive"] }
+flume = "0.10"
 futures-util = "0.3"
 log = "0.4"
 rand = "0.8"
@@ -16,5 +17,5 @@ structopt = "0.3"
 thiserror = "1"
 tokio = { version = "1", features = ["full"] }
 tokio-stream = "0.1"
-tokio-util = { version = "0.7", features = ["codec", "time"] }
+tokio-util = { version = "0.7", features = ["codec"] }
 uplink = { path = "../../uplink" }