snapshots method

Stream<InAppCounterSnapshot> snapshots()

Implementation

Stream<InAppCounterSnapshot> snapshots() {
  final n = _db._addNotifier(_p.path);
  Future.delayed(const Duration(seconds: 1)).whenComplete(_p._notify);
  return Stream.multi((c) {
    void update() {
      c.add(InAppCounterSnapshot(
        _p.id,
        n.value ?? InAppQuerySnapshot(_p.id),
        n.value?.docs.length ?? 0,
      ));
    }

    n.addListener(update);
    c.onCancel = () => n.removeListener(update);
  });
}