registerCompleter<T> method

  1. @protected
Future<T> registerCompleter<T>(
  1. int workId
)

Implementation

@protected
Future<T> registerCompleter<T>(int workId) {
  final completer = Completer<T>();
  assert(!_completers.containsKey(workId));
  final response = responseForWork(workId);
  if (response.available) {
    completeWork(completer, response);
  } else {
    assert(!_completers.containsKey(workId));
    _completers[workId] = completer;
  }
  return completer.future;
}