scheduleStream<T> method

StreamTask<T> scheduleStream<T>(
  1. Stream<T> task(
    1. ImageWorker worker
    ), {
  2. PerfCounter? counter,
})
inherited

Registers and schedules a task that returns a stream of values. Returns a StreamTask

Implementation

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