Export `Flume` and `Feed` from `piker.data`

basic_buy_bot
Tyler Goodlet 2023-06-26 15:21:30 -04:00
parent 49e67d5f36
commit cdf9105d0d
2 changed files with 9 additions and 2 deletions

View File

@ -35,11 +35,15 @@ from ._source import (
def_ohlcv_fields,
)
from .feed import (
Feed,
open_feed,
)
from .flows import Flume
__all__ = [
'Flume',
'Feed',
'open_feed',
'ShmArray',
'iterticks',

View File

@ -642,9 +642,12 @@ class Feed(Struct):
'''
mods: dict[str, ModuleType] = {}
portals: dict[ModuleType, tractor.Portal] = {}
flumes: dict[str, Flume] = {}
flumes: dict[
str, # FQME
Flume,
] = {}
streams: dict[
str,
str, # broker name
trio.abc.ReceiveChannel[dict[str, Any]],
] = {}