scheduleStreamTask<T> method

StreamTask<T> scheduleStreamTask<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 StreamTask.

Implementation

StreamTask<T> scheduleStreamTask<T>(Stream<T> Function(W worker) task,
        {PerfCounter? counter}) =>
    _enqueue<T>(WorkerStreamTask<T, W>(task, counter)) as StreamTask<T>;