| from typing import List, Optional | |
| from .loaders import Loader | |
| from .splitters import Splitter | |
| from .stream import MultiStream | |
| from .task import Tasker | |
| # class Fusion(StreamSource): | |
| # pass | |
| # class RecipeFusion(StreamSource): | |
| # recepies: List[Recipe] | |
| # def __call__(self) -> MultiStream: | |
| # for recipe in self.recepies: | |
| # stream = recipe() | |
| # return stream | |