in processor.py [0:0]
def match(self, part: ProcessorPart) -> bool:
return (
context_lib.is_reserved_substream(part.substream_name)
or not hasattr(self._part_processor_fn, 'match')
or self._part_processor_fn.match(part)
)