jc211
/
tractor
forked from goodboy/tractor
1
0
Fork 0
Code Pull Requests Activity

s/tickers/topics

contexts
Tyler Goodlet 2019-01-23 22:35:59 -05:00
parent 2b1e8773bb
commit 1b405ab4fe
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tractor/msg.py
View File

@ -68,21 +68,21 @@ def modify_subs(topics2ctxs, topics, ctx):
log.info(f"{ctx.chan.uid} changed subscription to {topics}") log.info(f"{ctx.chan.uid} changed subscription to {topics}")
# update map from each symbol to requesting client's chan # update map from each symbol to requesting client's chan
for ticker in topics: for topic in topics:
topics2ctxs.setdefault(ticker, set()).add(ctx) topics2ctxs.setdefault(topic, set()).add(ctx)
# remove any existing symbol subscriptions if symbol is not # remove any existing symbol subscriptions if symbol is not
# found in ``symbols`` # found in ``symbols``
# TODO: this can likely be factored out into the pub-sub api # TODO: this can likely be factored out into the pub-sub api
for ticker in filter( for topic in filter(
lambda topic: topic not in topics, topics2ctxs.copy() lambda topic: topic not in topics, topics2ctxs.copy()
): ):
ctx_set = topics2ctxs.get(ticker) ctx_set = topics2ctxs.get(topic)
ctx_set.discard(ctx) ctx_set.discard(ctx)
if not ctx_set: if not ctx_set:
# pop empty sets which will trigger bg quoter task termination # pop empty sets which will trigger bg quoter task termination
topics2ctxs.pop(ticker) topics2ctxs.pop(topic)
def pub( def pub(