OperationQueue<I, O> constructor

OperationQueue<I, O>({
  1. required Stream<O> task(
    1. I
    ),
  2. int concurrency = 1,
})

Implementation

OperationQueue({
  required Stream<O> Function(I) task,
  this.concurrency = 1,
}) {
  _taskWrapper.task = task;
  assert(concurrency >= 1, 'Concurrency must be 1 or more.');
}