pikers
/
piker
3
0
Fork 0
Code Issues 5 Pull Requests 7 Packages Projects Releases Wiki Activity

Accept a symbol type key from broker

basic_orders
Tyler Goodlet 2021-02-21 11:42:19 -05:00
parent 38b2e99002
commit 8c757d0bdd
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
piker/data/__init__.py
View File

@ -169,12 +169,6 @@ class Feed:
return self._index_stream return self._index_stream
def _set_fake_trades_stream(
self,
recv_chan: trio.abc.ReceiveChannel,
) -> None:
self._trade_stream = recv_chan
async def recv_trades_data(self) -> AsyncIterator[dict]: async def recv_trades_data(self) -> AsyncIterator[dict]:
if not getattr(self.mod, 'stream_trades', False): if not getattr(self.mod, 'stream_trades', False):
@ -187,7 +181,7 @@ class Feed:
# NOTE: this can be faked by setting a rx chan # NOTE: this can be faked by setting a rx chan
# using the ``_.set_fake_trades_stream()`` method # using the ``_.set_fake_trades_stream()`` method
if not self._trade_stream: if self._trade_stream is None:
self._trade_stream = await self._brokerd_portal.run( self._trade_stream = await self._brokerd_portal.run(
@ -254,6 +248,7 @@ async def open_feed(
# compat with eventual ``tractor.msg.pub`` # compat with eventual ``tractor.msg.pub``
topics=symbols, topics=symbols,
loglevel=loglevel,
) )
feed = Feed( feed = Feed(
@ -275,6 +270,7 @@ async def open_feed(
symbol = Symbol( symbol = Symbol(
key=sym, key=sym,
type_key=si.get('asset_type', 'forex'),
tick_size=si.get('price_tick_size', 0.01), tick_size=si.get('price_tick_size', 0.01),
lot_tick_size=si.get('lot_tick_size', 0.0), lot_tick_size=si.get('lot_tick_size', 0.0),
) )