base

2 files changed, 10 insertions, 21 deletions

diff --git a/libs/shared/src/nats.rs b/libs/shared/src/nats.rs
index 1d835d3..7d4d3d1 100644
--- a/libs/shared/src/nats.rs
+++ b/libs/shared/src/nats.rs
@@ -1,7 +1,4 @@
-use std::{
-    future::{Future, IntoFuture},
-    pin::Pin,
-};
+use std::{future::Future, pin::Pin};
 
 use async_nats::Client;
 use serde::Deserialize;
@@ -11,12 +8,8 @@ pub struct Configuration {
     pub host: String,
 }
 
-impl IntoFuture for Configuration {
-    type Output = anyhow::Result<Client>;
-
-    type IntoFuture = Pin<Box<dyn Future<Output = Self::Output> + Send>>;
-
-    fn into_future(self) -> Self::IntoFuture {
-        Box::pin(async move { Ok(async_nats::connect(self.host).await?) })
+impl From<Configuration> for Pin<Box<dyn Future<Output = anyhow::Result<Client>> + Send>> {
+    fn from(value: Configuration) -> Self {
+        Box::pin(async move { Ok(async_nats::connect(value.host).await?) })
     }
 }
diff --git a/libs/shared/src/redis.rs b/libs/shared/src/redis.rs
index 5cae869..77aa97f 100644
--- a/libs/shared/src/redis.rs
+++ b/libs/shared/src/redis.rs
@@ -1,22 +1,18 @@
 use redis::{aio::MultiplexedConnection, Client};
 use serde::Deserialize;
-use std::{
-    future::{Future, IntoFuture},
-    pin::Pin,
-};
+use std::{future::Future, pin::Pin};
 
 #[derive(Clone, Debug, Deserialize)]
 pub struct Configuration {
     pub url: String,
 }
 
-impl IntoFuture for Configuration {
-    type Output = anyhow::Result<MultiplexedConnection>;
-    type IntoFuture = Pin<Box<dyn Future<Output = Self::Output> + Send>>;
-
-    fn into_future(self) -> Self::IntoFuture {
+impl From<Configuration>
+    for Pin<Box<dyn Future<Output = anyhow::Result<MultiplexedConnection>> + Send>>
+{
+    fn from(value: Configuration) -> Self {
         Box::pin(async move {
-            let con = Client::open(self.url)?;
+            let con = Client::open(value.url)?;
             let (multiplex, ready) = con.create_multiplexed_tokio_connection().await?;
 
             tokio::spawn(ready);