Refactor streaming logic to be less nested and readable
parent
9706803220
commit
dae56baeba
|
@ -530,7 +530,6 @@ async def stream_quotes(
|
||||||
|
|
||||||
@acm
|
@acm
|
||||||
async def subscribe(ws: wsproto.WSConnection, connect_id, sym):
|
async def subscribe(ws: wsproto.WSConnection, connect_id, sym):
|
||||||
# breakpoint()
|
|
||||||
# level 2 sub
|
# level 2 sub
|
||||||
await ws.send_msg({
|
await ws.send_msg({
|
||||||
'id': connect_id,
|
'id': connect_id,
|
||||||
|
|
Loading…
Reference in New Issue