diff --git a/flow/ThreadHelper.actor.h b/flow/ThreadHelper.actor.h index f92f29294e..6e2569ed0e 100644 --- a/flow/ThreadHelper.actor.h +++ b/flow/ThreadHelper.actor.h @@ -638,7 +638,7 @@ ThreadFuture()().getValue())> onMainThread(F f) { Promise signal; auto returnValue = new ThreadSingleAssignmentVar()().getValue())>(); returnValue->addref(); // For the ThreadFuture we return - // TODO: Is this cancellation logic actually needed? + // TODO: Is this cancellation logic actually needed? Future cancelFuture = internal_thread_helper::doOnMainThread()().getValue()), F>( signal.getFuture(), f, returnValue); returnValue->setCancel(std::move(cancelFuture));