SaveEventsAtVersion<E, V> typedef

SaveEventsAtVersion<E, V> = Stream<(E, V)> Function(Stream<E> events, V? latestVersion)

Saves events using an explicit latest expected version.

Implementation

typedef SaveEventsAtVersion<E, V> =
    Stream<(E, V)> Function(Stream<E> events, V? latestVersion);