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(())