File size: 398 Bytes
1a724e9
5852323
 
 
1a724e9
5852323
 
1a724e9
 
5852323
 
1a724e9
 
5852323
1a724e9
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
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