Logic factoring
parent
1866dd1812
commit
b4fad3f6a9
|
@ -147,11 +147,8 @@ async def fan_out_to_chans(
|
||||||
"""Get quotes for current symbol subscription set.
|
"""Get quotes for current symbol subscription set.
|
||||||
"""
|
"""
|
||||||
symbols = list(symbols2chans.keys())
|
symbols = list(symbols2chans.keys())
|
||||||
if symbols:
|
# subscription can be changed at any time
|
||||||
# subscription can be changed at any time
|
return await get_quotes(symbols) if symbols else ()
|
||||||
return await get_quotes(symbols)
|
|
||||||
else:
|
|
||||||
return ()
|
|
||||||
|
|
||||||
async for quotes in stream_quotes(
|
async for quotes in stream_quotes(
|
||||||
feed.mod, request, rate,
|
feed.mod, request, rate,
|
||||||
|
|
Loading…
Reference in New Issue