onSnapshotSync method

Stream<RecordSnapshot<K, V>?> onSnapshotSync(
  1. Database database
)

Find first record (null if none) and listen for changes.

First emit happens synchronously.

Returns a single subscriber stream that must be cancelled.

Implementation

Stream<RecordSnapshot<K, V>?> onSnapshotSync(Database database) {
  if (sembastQueryRef.finder?.limit != 1) {
    return SembastQueryRef(sembastQueryRef.store,
            cloneFinderFindFirst(sembastQueryRef.finder))
        .onSnapshotSync(database);
  }
  return onSnapshotsSync(database)
      .map((list) => list.isNotEmpty ? list.first : null);
}