Rx symbol data from daemon as first response
parent
fcaeeae618
commit
995851360d
|
@ -387,10 +387,9 @@ async def _async_main(name, client, tickers, brokermod, rate):
|
||||||
|
|
||||||
This is started with cli command `piker watch`.
|
This is started with cli command `piker watch`.
|
||||||
'''
|
'''
|
||||||
# get initial symbol data
|
# get initial symbol data (long term data including last days close price)
|
||||||
async with brokermod.get_client() as bclient:
|
# TODO: need something better this this toy protocol
|
||||||
# get long term data including last days close price
|
sd = await client.recv()
|
||||||
sd = await bclient.symbol_data(tickers)
|
|
||||||
|
|
||||||
async with trio.open_nursery() as nursery:
|
async with trio.open_nursery() as nursery:
|
||||||
# get first quotes response
|
# get first quotes response
|
||||||
|
|
Loading…
Reference in New Issue