SaveEventsWithProvider<E, V> typedef

SaveEventsWithProvider<E, V> = Stream<(E, V)> Function(Stream<E> events, LatestVersionProvider<E, V> latestVersionProvider)

Saves events using a provider for the latest expected version.

Implementation

typedef SaveEventsWithProvider<E, V> =
    Stream<(E, V)> Function(
      Stream<E> events,
      LatestVersionProvider<E, V> latestVersionProvider,
    );