remove unused dependencies (#12)

* remove unused dependencies

* increase transaction page by 1ms

Cargo.toml

@@ -38,23 +38,19 @@ default = []
 sql = ["sqlx"]
 
 [dependencies]
-trait-variant = { version = "0.1.0"}
 serde_json = "1"
 serde = "1.0.195"
 serde_derive = { version = "1"}
 jsonwebtoken = "9"
 reqwest = { version = "0.12", default-features = true, features = ["json"] }
 tokio = { version = "1", default-features = false,  features = ["time"] }
-tokio-stream = {version = "0.1" }
 thiserror = "1"
 bigdecimal = { version = "^0.3", features = ["serde"] }
 url = "2"
 chrono = { version = "0.4", default-features = true, features = ["serde"] }
-pretty_assertions = "1.4.0"
 tracing = {  version = "0.1" }
 tokio-util = { version = "0.7", features = ["rt"] }
 futures = { version = "0.3" }
-human-panic = { version = "2" }
 sha2 = "0.10"
 rand = "0.8"
 sqlx = { version = "0.7", features = ["postgres"], optional = true }
@@ -70,4 +66,4 @@ rstest = { version = "0.19" }
 color-eyre = { version = "0.6" }
 lazy_static = "1.4.0"
 dotenvy = { version = "0.15" }
-ensure = "0.3"
+tokio-stream = {version = "0.1" }

src/paged_client.rs

@@ -153,8 +153,7 @@ impl Stream for TransactionStream {
               }
               if let Some(last) = va.last() {
                 tracing::debug!("1st after {:#?} last after {:#?}", va[0].created_at, last.created_at);
-                self.after = last.created_at + chrono::Duration::milliseconds(100);
-                //TODO possible to miss a transaction
+                self.after = last.created_at + chrono::Duration::milliseconds(1);
               }
             },
             Err(e) => {