collectionWithInjectedBoth<T> function

  1. @visibleForTesting
AtCollection<T> collectionWithInjectedBoth<T>(
  1. AtClient atClient,
  2. String namespace,
  3. Duration defaultExpiration, {
  4. required Stream<AtNotification> notifications,
  5. required Stream<DataEvent> dataEvents,
  6. T fromJson(
    1. Map<String, dynamic>
    )?,
  7. String? typeTag,
})

Constructs an AtCollection<T> on the EventSource.both path with both source streams injected: tests drive each path independently and assert un-deduplicated dual emission.

Implementation

@visibleForTesting
AtCollection<T> collectionWithInjectedBoth<T>(
  AtClient atClient,
  String namespace,
  Duration defaultExpiration, {
  required Stream<AtNotification> notifications,
  required Stream<DataEvent> dataEvents,
  T Function(Map<String, dynamic>)? fromJson,
  String? typeTag,
}) =>
    AtCollection<T>._withInjectedBoth(
      atClient,
      namespace,
      defaultExpiration,
      notifications: notifications,
      dataEvents: dataEvents,
      fromJson: fromJson,
      typeTag: typeTag,
    );