feat: glommio support

Cargo.toml

@@ -59,7 +59,9 @@ subscriber-client = ["i-pubsub"]
 transactions = []
 trust-dns-resolver = ["dep:trust-dns-resolver"]
 unix-sockets = []
-glommio = ["dep:glommio", "futures-io", "pin-project", "rm-send-macros/enabled", "async-oneshot"]
+
+# Enable experimental support for the Glommio runtime.
+glommio = ["dep:glommio", "futures-io", "pin-project", "rm-send-macros/enabled", "oneshot", "futures-lite"]
 
 # Enables rustls with the rustls/aws_lc_rs crypto backend
 enable-rustls = [
@@ -193,7 +195,8 @@ urlencoding = "2.1"
 glommio = { version = "0.9.0", optional = true }
 futures-io = { version = "0.3", optional = true }
 pin-project = { version = "1.1.5", optional = true }
-async-oneshot = { version = "0.5", optional = true }
+oneshot = { version = "0.1.8", optional = true, features = ["async"] }
+futures-lite = { version = "2.3", optional = true }
 rm-send-macros = { git = "https://github.com/aembke/rm-send-macros" }
 
 [dev-dependencies]

examples/pubsub.rs

@@ -9,7 +9,12 @@ use tokio::time::sleep;
 
 #[tokio::main]
 async fn main() -> Result<(), RedisError> {
-  let publisher_client = RedisClient::default();
+  let publisher_client = Builder::default_centralized()
+    .with_performance_config(|config| {
+      // change the buffer size of the broadcast channels used by the EventInterface
+      config.broadcast_channel_capacity = 64;
+    })
+    .build()?;
   let subscriber_client = publisher_client.clone_new();
   publisher_client.init().await?;
   subscriber_client.init().await?;