Open feeds using `Portal.open_context()`

piker/data/feed.py

@@ -519,19 +519,20 @@ async def open_sample_step_stream(
     # created for all practical purposes
     async with maybe_open_context(
         acm_func=partial(
-            portal.open_stream_from,
+            portal.open_context,
             iter_ohlc_periods,
         ),
         kwargs={'delay_s': delay_s},
 
-    ) as (cache_hit, istream):
+    ) as (cache_hit, (ctx, first)):
-        if cache_hit:
+        async with ctx.open_stream() as istream:
-            # add a new broadcast subscription for the quote stream
+            if cache_hit:
-            # if this feed is likely already in use
+                # add a new broadcast subscription for the quote stream
-            async with istream.subscribe() as bistream:
+                # if this feed is likely already in use
-                yield bistream
+                async with istream.subscribe() as bistream:
-        else:
+                    yield bistream
-            yield istream
+            else:
+                yield istream
 
 
 @dataclass