onKeySync method

Stream<K?> onKeySync(
  1. Database database
)

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

First emit happens synchronously.

Returns a single subscriber stream that must be cancelled.

Implementation

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