stream<T> method

Stream<T> stream<T>(
  1. Stream<T> task(
    1. WalletTasksWorker worker
    ), {
  2. PerfCounter? counter,
})
inherited

Registers and schedules a task that returns a stream of values. Returns a stream containing the task's values.

Implementation

Stream<T> stream<T>(Stream<T> Function(W worker) task,
        {PerfCounter? counter}) =>
    scheduleStreamTask(task, counter: counter).stream;