Hot fix 0.14.2

examples/deribit/check_is_connected.py

@@ -4,21 +4,34 @@
 
 conn = Deribit()
 
-print("Is connected after init", conn.is_connected())
-
+loop = asyncio.get_event_loop()
 
-def close():
-    print("Check connection  before closing", conn.is_connected())
-    asyncio.ensure_future(conn.stop())
+i = 0
+def check():
+    global i
+    i += 1
+    print("Check connection  ", conn.is_connected())
+    loop.call_later(1, close, i < 2)
 
+def run():
+    print("Is connected before run_receiver() ", conn.is_connected())
+    asyncio.ensure_future(conn.run_receiver())
+    loop.call_later(1, check)
 
-loop = asyncio.get_event_loop()
+def close(restart: bool = True):
+    print("Is connection before closing", conn.is_connected())
+    asyncio.ensure_future(conn.stop())
+    if restart:
+        loop.call_later(2, run)
 
+def stop():
+    loop.call_later(1, loop.stop)
 
-loop.call_later(1, close)
+loop.call_later(10, stop)
+loop.call_soon(run)
 
 try:
-    loop.run_until_complete(conn.run_receiver())
+    loop.run_forever()
 except KeyboardInterrupt:
     print("Application closed by KeyboardInterrupt.")
 

ssc2ce/common/session.py

@@ -180,7 +180,11 @@ async def public_get(self, request_path, params=None):
 
     async def stop(self):
         await self.ws.close()
-        await self._session.close()
+
+        if self.__internal_session and self.__session:
+            await self.__session.close()
+            self.__session = None
+            self.__is_session = False
 
     def is_connected(self) -> bool:
         if self.ws is None: