(
self,
stream_spec,
name,
incoming_stream_types,
outgoing_stream_type,
min_inputs,
max_inputs,
args=[],
kwargs={},
)
| 187 | return incoming_edge_map |
| 188 | |
| 189 | def __init__( |
| 190 | self, |
| 191 | stream_spec, |
| 192 | name, |
| 193 | incoming_stream_types, |
| 194 | outgoing_stream_type, |
| 195 | min_inputs, |
| 196 | max_inputs, |
| 197 | args=[], |
| 198 | kwargs={}, |
| 199 | ): |
| 200 | stream_map = get_stream_map(stream_spec) |
| 201 | self.__check_input_len(stream_map, min_inputs, max_inputs) |
| 202 | self.__check_input_types(stream_map, incoming_stream_types) |
| 203 | incoming_edge_map = self.__get_incoming_edge_map(stream_map) |
| 204 | |
| 205 | super(Node, self).__init__(incoming_edge_map, name, args, kwargs) |
| 206 | self.__outgoing_stream_type = outgoing_stream_type |
| 207 | self.__incoming_stream_types = incoming_stream_types |
| 208 | |
| 209 | def stream(self, label=None, selector=None): |
| 210 | """Create an outgoing stream originating from this node. |
no test coverage detected