Skip to content

BuildPhase

Source code in event_sourcery/_event_store/subscription/interfaces.py 
85
86
87
88
89
90
91
92
93
94
class BuildPhase:
    def build_iter(self, timelimit: Seconds | timedelta) -> Iterator[Recorded | None]:
        raise NotImplementedError()

    def build_batch(
        self,
        size: int,
        timelimit: Seconds | timedelta,
    ) -> Iterator[list[Recorded]]:
        raise NotImplementedError()