diff --git a/bfxapi/utils/decorators.py b/bfxapi/utils/decorators.py
index b226edc..3a4fe9a 100644
--- a/bfxapi/utils/decorators.py
+++ b/bfxapi/utils/decorators.py
@@ -2,10 +2,10 @@ from ..utils.custom_logger import CustomLogger
 
 
 def handle_failure(func):
-    def inner_function(*args, **kwargs):
+    async def inner_function(*args, **kwargs):
         logger = CustomLogger('BfxWebsocket', logLevel="DEBUG")
         try:
-            func(*args, **kwargs)
+            await func(*args, **kwargs)
         except Exception as exception_message:
             logger.error(exception_message)