From 832e4c97d2b29861ee2125f338353c842e18a1cb Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Mon, 21 Feb 2022 13:08:04 -0500
Subject: [PATCH] Drop shm: ShmArray` to `stream_quotes()` endpoint

---
 piker/brokers/binance.py |  1 -
 piker/brokers/ib.py      | 10 +++++-----
 piker/brokers/kraken.py  |  1 -
 3 files changed, 5 insertions(+), 7 deletions(-)

diff --git a/piker/brokers/binance.py b/piker/brokers/binance.py
index 4d82474b..f4732e54 100644
--- a/piker/brokers/binance.py
+++ b/piker/brokers/binance.py
@@ -386,7 +386,6 @@ async def stream_quotes(
 
     send_chan: trio.abc.SendChannel,
     symbols: List[str],
-    shm: ShmArray,
     feed_is_live: trio.Event,
     loglevel: str = None,
 
diff --git a/piker/brokers/ib.py b/piker/brokers/ib.py
index 5cf7d2f0..9f1bd49b 100644
--- a/piker/brokers/ib.py
+++ b/piker/brokers/ib.py
@@ -517,11 +517,11 @@ class Client:
         contract, ticker, details = await self.get_sym_details(symbol)
 
         # ensure a last price gets filled in before we deliver quote
-        for _ in range(2):
+        for _ in range(1):
             if isnan(ticker.last):
+                await asyncio.sleep(0.1)
                 log.warning(f'Quote for {symbol} timed out: market is closed?')
                 ticker = await ticker.updateEvent
-                await asyncio.sleep(0.1)
             else:
                 log.info(f'Got first quote for {symbol}')
                 break
@@ -1201,12 +1201,13 @@ async def backfill_bars(
     task_status: TaskStatus[trio.CancelScope] = trio.TASK_STATUS_IGNORED,
 
 ) -> None:
-    """Fill historical bars into shared mem / storage afap.
+    '''
+    Fill historical bars into shared mem / storage afap.
 
     TODO: avoid pacing constraints:
     https://github.com/pikers/piker/issues/128
 
-    """
+    '''
     if platform.system() == 'Windows':
         log.warning(
             'Decreasing history query count to 4 since, windows...')
@@ -1411,7 +1412,6 @@ async def stream_quotes(
 
     send_chan: trio.abc.SendChannel,
     symbols: list[str],
-    shm: ShmArray,
     feed_is_live: trio.Event,
     loglevel: str = None,
 
diff --git a/piker/brokers/kraken.py b/piker/brokers/kraken.py
index 24d2dab3..0d899428 100644
--- a/piker/brokers/kraken.py
+++ b/piker/brokers/kraken.py
@@ -406,7 +406,6 @@ async def stream_quotes(
 
     send_chan: trio.abc.SendChannel,
     symbols: List[str],
-    shm: ShmArray,
     feed_is_live: trio.Event,
     loglevel: str = None,