Method waited

include/process/collect.hpp:252–262

  }

  void waited(const Future<T>& future)
  {
    CHECK(!future.isPending());

    ready += 1;
    if (ready == futures.size()) {
      // It is safe to move futures at this point.
      promise->set(std::move(futures));
      terminate(this);
    }
  }

  std::vector<Future<T>> futures;
  Promise<std::vector<Future<T>>>* promise;