(self, ctx: Context, stream: str)
| 100 | return self._run_stream(ctx, stream, 'collector') |
| 101 | |
| 102 | def extract(self, ctx: Context, stream: str): |
| 103 | return self._run_stream(ctx, stream, 'extractor') |
| 104 | |
| 105 | def convert(self, ctx: Context, stream: str): |
| 106 | return self._run_stream(ctx, stream, 'convertor') |
nothing calls this directly
no test coverage detected