rust(feat): Refactor SiftStream internals for better nonblocking behavior (#350)

Author: tsift

rust/Cargo.lock

@@ -56,7 +56,7 @@ impl SiftChannelBuilder {
         let channel = Endpoint::from_shared(uri)
             .map(|conn| {
                 let mut chan = conn
-                    .keep_alive_while_idle(true)
+                    .keep_alive_while_idle(self.keep_alive_while_idle)
                     .keep_alive_timeout(self.keep_alive_timeout)
                     .http2_keep_alive_interval(self.keep_alive_interval)
                     .user_agent(self.user_agent)

rust/crates/sift_connect/src/grpc/mod.rs

@@ -22,10 +22,11 @@ sift_rs = { workspace = true }
 tracing = { version = "0.1.41", optional = true }
 bytesize = { version = "2", optional = true }
 pbjson-types = { workspace = true }
-tokio = { version = "1.43.0", features = ["rt", "sync", "time", "macros"] }
+tokio = { version = "1.43.0", features = ["rt", "sync", "time", "macros", "fs"] }
 chrono = { workspace = true }
 futures-core = "0.3.31"
-tokio-stream = "0.1.17"
+tokio-stream = { version = "0.1.17", features = ["sync"] }
+async-channel = "2.2"
 prost = "^0.13"
 dirs = "6.0.0"
 crc32fast = "1.4.2"