stream<T> method

Stream<T> stream<T>(
  1. Stream<T> executor(
    1. ScopedDatabase db
    )
)

Listens to the executor through a non-closed ScopedDatabase.

ScopedDatabase may be closed, for example, between E2E tests.

Implementation

Stream<T> stream<T>(Stream<T> Function(ScopedDatabase db) executor) {
  return _scoped.stream(executor);
}