PersistentSubscription constructor

PersistentSubscription(
  1. StreamSink<ReadReq> requests,
  2. ReadEnumerator<GeneratedMessage> enumerator, {
  3. required bool autoAck,
  4. required Future<void> onReplay(
    1. int? startAt
    ),
  5. PersistentSubscriptionResolvedEventCallback? onEventAppeared,
  6. SubscriptionDroppedCallback? onSubscriptionDropped,
})

Implementation

PersistentSubscription(
  StreamSink<ReadReq> requests,
  ReadEnumerator enumerator, {
  required this.autoAck,
  required Future<void> Function(int? startAt) onReplay,
  PersistentSubscriptionResolvedEventCallback? onEventAppeared,
  SubscriptionDroppedCallback? onSubscriptionDropped,
})  : _onReplay = onReplay,
      _requests = requests,
      super(
        enumerator,
        onSubscriptionDropped: onSubscriptionDropped,
        onEventAppeared: (s, e) => _onAppeared(
          s,
          e,
          autoAck,
          requests,
          onEventAppeared,
        ),
      );