Skip to content

FilterPhase

Bases: BuildPhase

Source code in event_sourcery/_event_store/subscription/interfaces.py
class FilterPhase(BuildPhase):
    def to_category(self, category: StreamCategory) -> BuildPhase:
        raise NotImplementedError()

    def to_events(self, events: list[type[Event]]) -> BuildPhase:
        raise NotImplementedError()