Searched refs:cancellationRequested (Results 1 – 11 of 11) sorted by relevance
149 default boolean cancellationRequested() { in cancellationRequested() method264 public boolean cancellationRequested() { in cancellationRequested() method in Sink.ChainedReference265 return downstream.cancellationRequested(); in cancellationRequested()296 public boolean cancellationRequested() { in cancellationRequested() method in Sink.ChainedInt297 return downstream.cancellationRequested(); in cancellationRequested()328 public boolean cancellationRequested() { in cancellationRequested() method in Sink.ChainedLong329 return downstream.cancellationRequested(); in cancellationRequested()360 public boolean cancellationRequested() { in cancellationRequested() method in Sink.ChainedDouble361 return downstream.cancellationRequested(); in cancellationRequested()
321 public final boolean cancellationRequested() { in cancellationRequested() method in SortedOps.AbstractRefSortingSink355 for (int i = 0; i < offset && !downstream.cancellationRequested(); i++) in end()394 if (downstream.cancellationRequested()) break; in end()419 public final boolean cancellationRequested() { in cancellationRequested() method in SortedOps.AbstractIntSortingSink452 for (int i = 0; i < offset && !downstream.cancellationRequested(); i++) in end()493 if (downstream.cancellationRequested()) break; in end()517 public final boolean cancellationRequested() { in cancellationRequested() method in SortedOps.AbstractLongSortingSink550 for (int i = 0; i < offset && !downstream.cancellationRequested(); i++) in end()591 if (downstream.cancellationRequested()) break; in end()615 public final boolean cancellationRequested() { in cancellationRequested() method in SortedOps.AbstractDoubleSortingSink[all …]
216 public boolean cancellationRequested() { in makeRef() method217 return m == 0 || downstream.cancellationRequested(); in makeRef()328 public boolean cancellationRequested() {329 return m == 0 || downstream.cancellationRequested();440 public boolean cancellationRequested() {441 return m == 0 || downstream.cancellationRequested();552 public boolean cancellationRequested() {553 return m == 0 || downstream.cancellationRequested();
265 public boolean cancellationRequested() { in cancellationRequested() method in MatchOps.BooleanTerminalSink
185 public boolean cancellationRequested() { in cancellationRequested() method in FindOps.FindSink
288 while (!isShortCircuit || !taskSink.cancellationRequested()) { in compute()
166 do { } while (!sink.cancellationRequested() && spl.tryAdvance(adaptedSink)); in forEachWithCancel()
169 do { } while (!sink.cancellationRequested() && spl.tryAdvance(adaptedSink)); in forEachWithCancel()
167 do { } while (!sink.cancellationRequested() && spl.tryAdvance(adaptedSink)); in forEachWithCancel()
133 do { } while (!sink.cancellationRequested() && spliterator.tryAdvance(sink)); in forEachWithCancel()
206 if (bufferSink.cancellationRequested() || !pusher.getAsBoolean()) {