stream<T> method

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

Listens to the executor through a non-closed CommonDatabase.

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

Implementation

Stream<T> stream<T>(Stream<T> Function(CommonDatabase db) executor) {
  return _provider.stream(executor);
}