diff --git a/piker/brokers/deribit/api.py b/piker/brokers/deribit/api.py index 15a9f88f..332681f6 100644 --- a/piker/brokers/deribit/api.py +++ b/piker/brokers/deribit/api.py @@ -831,6 +831,31 @@ async def aio_open_interest_feed_relay( await asyncio.sleep(float('inf')) +@acm +async def open_oi_feed( +) -> to_asyncio.LinkedTaskChannel: + + instruments: list[Symbol] + async with get_client( + ) as client: + instruments = await client.get_instruments() + + fh: FeedHandler + first: None + chan: to_asyncio.LinkedTaskChannel + async with ( + maybe_open_feed_handler() as fh, + to_asyncio.open_channel_from( + partial( + aio_open_interest_feed_relay, + fh, + instruments + ) + ) as (first, chan) + ): + yield chan + + # TODO, move all to `.broker` submod! # async def aio_order_feed_relay(