Method Execute

test/cpp/asyncprogressqueueworkerstream.cpp:34–42

  }

  void Execute (
    const typename AsyncProgressQueueWorker<T>::ExecutionProgress& progress) {
    data_t data;
    for (int i = 0; i < iters; ++i) {
      data.index = i;
      data.data = i * 2;
      progress.Send(&data, 1);
    }
  }

  void HandleProgressCallback(const T *data, size_t count) {
    HandleScope scope;