process method

  1. @override
Future<O> process(
  1. I input
)
override

Process the given input in a the spawned process.

Implementation

@override
Future<O> process(I input) {
  return _processGroup[(_workerIndex++ % _processGroup.length)].process(input);
}