createRepositoryEventsSubscriptions<T> function

IEventsSubscriptions<T> createRepositoryEventsSubscriptions<T>(
  1. IEventRepository<T> repository, {
  2. StreamTransformer<T, T>? transformAll,
  3. StreamModifier<T>? modifyAll,
})

Implementation

IEventsSubscriptions<T> createRepositoryEventsSubscriptions<T>(
  IEventRepository<T> repository, {
  StreamTransformer<T, T>? transformAll,
  StreamModifier<T>? modifyAll,
}) =>
    EventsSubscriptions<T>(repository.stream, transformAll: transformAll, modifyAll: modifyAll);