diff --git a/binance/threaded_stream.py b/binance/threaded_stream.py
index dbe182013..21413b920 100755
--- a/binance/threaded_stream.py
+++ b/binance/threaded_stream.py
@@ -16,7 +16,7 @@ def __init__(
 
         """
         super().__init__()
-        self._loop: asyncio.AbstractEventLoop = asyncio.new_event_loop()
+        self._loop: asyncio.AbstractEventLoop = asyncio.get_event_loop()
         self._client: Optional[AsyncClient] = None
         self._running: bool = True
         self._socket_running: Dict[str, bool] = {}