Searched refs:taskSink (Results 1 – 1 of 1) sorted by relevance
286 Sink<S> taskSink = sink; in compute() local288 while (!isShortCircuit || !taskSink.cancellationRequested()) { in compute()291 task.helper.copyInto(taskSink, rightSplit); in compute()