From 241b7a38147ba3ce3aaac7ea984914b24364c535 Mon Sep 17 00:00:00 2001
From: Lucas Colombo <lucasncolombo@gmail.com>
Date: Thu, 23 May 2024 20:36:02 -0300
Subject: [PATCH] =?UTF-8?q?feat:=20=E2=9C=A8=20rustler:=20make=20on=5Fadd?=
 =?UTF-8?q?=20and=20on=5Fdelete=20async?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 examples/binance/mod.rs | 4 ++--
 lib/rustlers/rustler.rs | 8 ++++----
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/examples/binance/mod.rs b/examples/binance/mod.rs
index e1e11b3..d47bbb8 100644
--- a/examples/binance/mod.rs
+++ b/examples/binance/mod.rs
@@ -99,12 +99,12 @@ impl Rustler for FooRustler {
         Ok(())
     }
 
-    fn on_add(&mut self, tickers: &[Ticker]) -> Result<()> {
+    async fn on_add(&mut self, tickers: &[Ticker]) -> Result<()> {
         info!("(mock) Adding tickers: {:?}", tickers);
         Ok(())
     }
 
-    fn on_delete(&mut self, tickers: &[Ticker]) -> Result<()> {
+    async fn on_delete(&mut self, tickers: &[Ticker]) -> Result<()> {
         info!("(mock) Deleting tickers: {:?}", tickers);
         Ok(())
     }
diff --git a/lib/rustlers/rustler.rs b/lib/rustlers/rustler.rs
index de07dfa..a6b9290 100644
--- a/lib/rustlers/rustler.rs
+++ b/lib/rustlers/rustler.rs
@@ -253,9 +253,9 @@ pub trait RustlerAccessor {
 pub trait Rustler: RustlerAccessor + Send + Sync {
     // #region Unimplemented trait functions
     /// 🐎 » fn called after tickers are added to the rustler
-    fn on_add(&mut self, tickers: &[Ticker]) -> Result<()>;
+    async fn on_add(&mut self, tickers: &[Ticker]) -> Result<()>;
     /// 🐎 » fn called after tickers are deleted from the rustler
-    fn on_delete(&mut self, tickers: &[Ticker]) -> Result<()>;
+    async fn on_delete(&mut self, tickers: &[Ticker]) -> Result<()>;
     /// 🐎 » connects the rustler to the data source
     async fn connect(&mut self) -> Result<()>;
     /// 🐎 » disconnects the rustler from the data source
@@ -323,7 +323,7 @@ pub trait Rustler: RustlerAccessor + Send + Sync {
         }
 
         if !added_tickers.is_empty() {
-            self.on_add(&added_tickers)?;
+            self.on_add(&added_tickers).await?;
         }
 
         Ok(())
@@ -348,7 +348,7 @@ pub trait Rustler: RustlerAccessor + Send + Sync {
         }
 
         if !removed_tickers.is_empty() {
-            self.on_delete(&removed_tickers)?;
+            self.on_delete(&removed_tickers).await?;
         }
 
         Ok(())