Fix high-frequency changes skips on re-subscription (#90)

* log a warning if the body sender sees a non-contiguous change id * upgrade tokio, maybe that's a bug that's been fixed * log dupped change ids as well as smaller ones * start writing bytes to body earlier * wait for all rows to be sent before handling changes in parallel
superfly · Nov 16, 2023 · 3951018 · 3951018
1 parent 1c5096b
commit 3951018
Show file tree

Hide file tree

Showing 4 changed files with 164 additions and 168 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -3,6 +3,7 @@ members = [
 	"crates/*",
 	"integration-tests"
 ]
+resolver = "2"
 
 [workspace.dependencies]
 arc-swap = { version = "1.6.0" }
@@ -63,7 +64,7 @@ strum = { version = "0.24.1", features = ["derive"] }
 tempfile = "3.5.0"
 thiserror = "1.0.40"
 time = { version = "0.3.15", features = ["macros", "serde-well-known"] }
-tokio = { version = "1", features = ["full"] }
+tokio = { version = "1.34", features = ["full"] }
 tokio-metrics = "0.3.0"
 tokio-serde = { version = "0.8", features = ["json"] }
 tokio-stream = { version = "0.1.12", features = ["sync"] }