submit<Q, R> method

  1. @override
Future<R> submit<Q, R>(
  1. Job<Q, R> job
)
override

Implementation

@override
Future<R> submit<Q, R>(Job<Q, R> job) {
  if (disposed) {
    return Future.error(CancellationException());
  }
  final internalJob = _InternalJob<Q, R>(job);
  _queue.add(internalJob);
  _applyQueueLimit();
  _startJobs();
  return internalJob.completer.future;
}