Skip to content

Aggregate

Source code in event_sourcery/event_sourcing/aggregate.py 
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
class Aggregate:
    category: ClassVar[str]
    _changes: list[Event]

    @contextmanager
    def __persisting_changes__(self) -> Iterator[Iterator[Event]]:
        yield iter(getattr(self, "_changes", []))
        self._changes = []

    def __apply__(self, event: Event) -> None:
        raise NotImplementedError

    def _emit(self, event: Event) -> None:
        if not hasattr(self, "_changes"):
            self._changes = []
        self.__apply__(event)
        self._changes.append(event)