pikers
/
piker
3
0
Fork 0
Code Issues 4 Pull Requests 6 Packages Projects Releases Wiki Activity

Pass through rate arg to `poll_tickers`

kivy_mainline_and_py3.8
Tyler Goodlet 2018-03-21 17:26:30 -04:00
parent 456e86990f
commit 1ea784558c
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
piker/ui/watchlist.py
View File

@ -7,6 +7,7 @@ Launch with ``piker watch <watchlist name>``.
""" """
from itertools import chain from itertools import chain
from types import ModuleType from types import ModuleType
from functools import partial
import trio import trio
from kivy.uix.boxlayout import BoxLayout from kivy.uix.boxlayout import BoxLayout
@ -383,7 +384,7 @@ async def run_kivy(root, nursery):
nursery.cancel_scope.cancel() # cancel all other tasks that may be running nursery.cancel_scope.cancel() # cancel all other tasks that may be running
async def _async_main(name, tickers, brokermod): async def _async_main(name, tickers, brokermod, rate):
'''Launch kivy app + all other related tasks. '''Launch kivy app + all other related tasks.
This is started with cli command `piker watch`. This is started with cli command `piker watch`.
@ -395,7 +396,9 @@ async def _async_main(name, tickers, brokermod):
sd = await client.symbols(tickers) sd = await client.symbols(tickers)
nursery.start_soon( nursery.start_soon(
poll_tickers, client, brokermod.quoter, tickers, queue) partial(poll_tickers, client, brokermod.quoter, tickers, queue,
rate=rate)
)
# get first quotes response # get first quotes response
pkts = await queue.get() pkts = await queue.get()