(self, upstream_node, upstream_label, upstream_selector=None)
| 321 | |
| 322 | class OutputStream(Stream): |
| 323 | def __init__(self, upstream_node, upstream_label, upstream_selector=None): |
| 324 | super(OutputStream, self).__init__( |
| 325 | upstream_node, |
| 326 | upstream_label, |
| 327 | {OutputNode, GlobalNode, MergeOutputsNode}, |
| 328 | upstream_selector=upstream_selector, |
| 329 | ) |
| 330 | |
| 331 | |
| 332 | # noinspection PyMethodOverriding |