diff --git a/piker/brokers/ib/broker.py b/piker/brokers/ib/broker.py index 3303d9dc..c2f03a4f 100644 --- a/piker/brokers/ib/broker.py +++ b/piker/brokers/ib/broker.py @@ -616,7 +616,7 @@ async def trades_dialogue( trio.open_nursery() as n, ): - for client in aioclients.values(): + for client in set(aioclients.values()): trade_event_stream = await n.start( open_trade_event_stream, client,