Method run

python/pathway/tests/test_io.py:1213–1215

(self)

    class MySubject(pw.io.python.ConnectorSubject):
        def run(self) -> None:
            for i in range(4):
                self.next(a=i, b=f"x{i}")

        @property
        def _deletions_enabled(self) -> bool: