stream method

Stream<RecordSnapshot<K, V>> stream(
  1. DatabaseClient databaseClient, {
  2. Filter? filter,
})

Unsorted record stream

Implementation

Stream<RecordSnapshot<K, V>> stream(
  DatabaseClient databaseClient, {
  Filter? filter,
}) {
  final client = getClient(databaseClient);

  return client
      .getSembastStore(this)
      .txnGetStream(client.sembastTransaction, filter);
}