Switch back to using async for and dont install signal handlers on cryptofeed

piker/brokers/deribit/api.py

@@ -613,7 +613,9 @@ class CryptoFeedRelay:
                     })
 
                 if not self._fh.running:
-                    self._fh.run(start_loop=False)
+                    self._fh.run(
+                        start_loop=False,
+                        install_signal_handlers=False)
                     self._loop = asyncio.get_event_loop()
 
                 # sync with trio
@@ -664,7 +666,9 @@ class CryptoFeedRelay:
                     })
 
                 if not self._fh.running:
-                    self._fh.run(start_loop=False)
+                    self._fh.run(
+                        start_loop=False,
+                        install_signal_handlers=False)
                     self._loop = asyncio.get_event_loop()
 
                 # sync with trio

piker/brokers/deribit/feed.py

@@ -154,10 +154,10 @@ async def stream_quotes(
 
             if len(last_trades) == 0:
                 last_trade = None
-                while not last_trade:
-                    typ, quote = await stream.receive()
+                async for typ, quote in stream:
                     if typ == 'trade':
                         last_trade = Trade(**(quote['data']))
+                        break
 
             else:
                 last_trade = Trade(**(last_trades[0]))
@@ -177,15 +177,10 @@ async def stream_quotes(
 
             feed_is_live.set()
 
-            try:
-                while True:
-                    typ, quote = await stream.receive() 
+            async for typ, quote in stream:
                 topic = quote['symbol']
                 await send_chan.send({topic: quote})
 
-            except trio.ClosedResourceError:
-                ...
-
 
 @tractor.context
 async def open_symbol_search(