whoops

Author: rundef

async_rithmic/plants/ticker.py

@@ -152,7 +152,7 @@ async def unsubscribe_from_market_depth(
         """
 
         sub = (symbol, exchange, depth_price)
-        self._subscriptions["market_depth"].add(sub)
+        self._subscriptions["market_depth"].discard(sub)
 
         await self._send_request(
             template_id=117,

docs/realtime_data.rst

@@ -191,6 +191,9 @@ Here's an example that streams full order book updates:
 
         await client.subscribe_to_market_data(security_code, exchange, DataType.ORDER_BOOK)
 
+        await asyncio.sleep(10)
+        await client.unsubscribe_from_market_data(security_code, exchange, DataType.ORDER_BOOK)
+
 Market Depth
 ------------