minor improvements

Cargo.toml

@@ -13,19 +13,19 @@ documentation = "https://docs.rs/rsmq_async/"
 readme = "README.md"
 
 [dependencies]
-lazy_static = "1"
-rand = "0.8"
-radix_fmt = "1"
-bb8 = "0.8"
-thiserror = "1"
-redis = { version = "0.25", features = ["tokio-comp", "async-std-comp"] }
-async-trait = "0.1"
+lazy_static = "^1"
+rand = "^0.8"
+radix_fmt = "^1"
+bb8 = "^0.8"
+thiserror = "^1"
+redis = { version = "^0.25", default-features = false, features = ["acl", "keep-alive", "script"] }
+async-trait = "^0.1"
 
 [dev-dependencies]
-net2 = "0.2"
-tokio = { version = "1", features = ["rt-multi-thread"]}
+net2 = "^0.2"
+tokio = { version = "^1", features = ["rt-multi-thread"]}
 
 [features]
-default = ["tokio-comp", "async-std-comp"]
+default = ["tokio-comp"]
 tokio-comp = ["redis/tokio-comp"]
 async-std-comp = ["redis/async-std-comp"]

src/error.rs

@@ -7,7 +7,7 @@ pub type RsmqResult<T> = Result<T, RsmqError>;
 
 /// This is the error type for any oprtation with this
 /// library. It derives `ThisError`
-#[derive(ThisError, Debug)]
+#[derive(ThisError, Debug, PartialEq)]
 pub enum RsmqError {
     #[error("Pool run error: `{0:?}`")]
     RunError(#[from] RunError<RedisError>),

src/lib.rs

@@ -130,7 +130,7 @@
 //! ```rust,ignore
 //!
 //! impl TryFrom<RedisBytes> for String {
-//!      
+//!
 //!     type Error = Vec<u8>; // Always set Error as Vec<u8>;
 //!
 //!     fn try_from(bytes: RedisBytes) -> Result<Self, Self::Error> {
@@ -154,7 +154,7 @@ mod types;
 pub use error::RsmqError;
 pub use error::RsmqResult;
 pub use multiplexed_facade::Rsmq;
-pub use pooled_facade::{PoolOptions, PooledRsmq};
+pub use pooled_facade::{PoolOptions, PooledRsmq, RedisConnectionManager};
 pub use r#trait::RsmqConnection;
 pub use types::RedisBytes;
 pub use types::RsmqMessage;

src/pooled_facade.rs

@@ -100,6 +100,21 @@ impl PooledRsmq {
             },
         })
     }
+
+    pub fn new_with_pool(
+        pool: bb8::Pool<RedisConnectionManager>,
+        realtime: bool,
+        ns: Option<&str>,
+    ) -> PooledRsmq {
+        PooledRsmq {
+            pool,
+            functions: RsmqFunctions {
+                ns: ns.unwrap_or("rsmq").to_string(),
+                realtime,
+                conn: PhantomData,
+            },
+        }
+    }
 }
 
 #[async_trait::async_trait]