diff --git a/piker/brokers/kucoin.py b/piker/brokers/kucoin.py index 8037d457..62b811ca 100644 --- a/piker/brokers/kucoin.py +++ b/piker/brokers/kucoin.py @@ -523,6 +523,7 @@ async def stream_quotes( typ, quote = await anext(msg_gen) while typ != 'trade': + # take care to not unblock here until we get a real trade quote typ, quote = await anext(msg_gen)