Merge pull request #3 from YinYin-blip/streamingapi

YinYin-blip · web-flow · commit 8be5204bf19a · 2026-03-28T16:08:12.000+02:00
Streamingapi
diff --git a/examples/stream.py b/examples/stream.py
@@ -8,11 +8,14 @@ def handle_update(pair, state, update):
     if update is not None:
         print(update)
 
-asyncio.get_event_loop().run_until_complete(
-    stream_market(
+async def main():
+    await stream_market(
         pair="XBTZAR",
         api_key_id="", # API Key goes here
         api_key_secret="", # and API Secret goes here
         update_callback=handle_update,
     )
-)
+
+
+if __name__ == "__main__":
+    asyncio.run(main())
diff --git a/luno_python/stream_client.py b/luno_python/stream_client.py
@@ -198,7 +198,6 @@ async def stream_market(
         })
         await websocket.send(auth)
 
-        await asyncio.gather(
-            _read_from_websocket(websocket, p, update_callback),
-            _write_keep_alive(websocket),
-        )
+        async with asyncio.TaskGroup() as tg:
+            tg.create_task(_read_from_websocket(websocket, p, update_callback))
+            tg.create_task(_write_keep_alive(websocket))
