| 152 | |
| 153 | @classmethod |
| 154 | def __check_input_len(cls, stream_map, min_inputs, max_inputs): |
| 155 | if min_inputs is not None and len(stream_map) < min_inputs: |
| 156 | raise ValueError( |
| 157 | 'Expected at least {} input stream(s); got {}'.format( |
| 158 | min_inputs, len(stream_map) |
| 159 | ) |
| 160 | ) |
| 161 | elif max_inputs is not None and len(stream_map) > max_inputs: |
| 162 | raise ValueError( |
| 163 | 'Expected at most {} input stream(s); got {}'.format( |
| 164 | max_inputs, len(stream_map) |
| 165 | ) |
| 166 | ) |
| 167 | |
| 168 | @classmethod |
| 169 | def __check_input_types(cls, stream_map, incoming_stream_types): |