diff --git a/piker/brokers/kucoin.py b/piker/brokers/kucoin.py index 63502099..b8d9c503 100644 --- a/piker/brokers/kucoin.py +++ b/piker/brokers/kucoin.py @@ -469,7 +469,7 @@ async def stream_quotes( l1_sub = make_sub(kucoin_sym, connect_id) await ws.send_msg(l1_sub) - yieldhttps: // github.com/pikers/piker/pull/494 + yield # unsub if ws.connected():