PersistentSubscription constructor
PersistentSubscription(
- StreamSink<
ReadReq> requests, - ReadEnumerator<
GeneratedMessage> enumerator, { - required bool autoAck,
- required Future<
void> onReplay(- int? startAt
- PersistentSubscriptionResolvedEventCallback? onEventAppeared,
- 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,
),
);