From bc5a37215b24a9255a2c92aa0f81bddba670d8a5 Mon Sep 17 00:00:00 2001
From: Nelson Torres <nelson.torres.alvarado1@gmail.com>
Date: Thu, 30 Jan 2025 01:39:42 +0000
Subject: [PATCH] open_oi_feed

---
 piker/brokers/deribit/api.py | 25 +++++++++++++++++++++++++
 1 file changed, 25 insertions(+)

diff --git a/piker/brokers/deribit/api.py b/piker/brokers/deribit/api.py
index 1760d0e1..b206a425 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(