Home
last modified time | relevance | path

Searched refs:cancellationRequested (Results 1 – 7 of 7) sorted by relevance

/libcore/ojluni/src/main/java/java/util/stream/
DSink.java149 default boolean cancellationRequested() { in cancellationRequested() method
264 public boolean cancellationRequested() { in cancellationRequested() method in Sink.ChainedReference
265 return downstream.cancellationRequested(); in cancellationRequested()
296 public boolean cancellationRequested() { in cancellationRequested() method in Sink.ChainedInt
297 return downstream.cancellationRequested(); in cancellationRequested()
328 public boolean cancellationRequested() { in cancellationRequested() method in Sink.ChainedLong
329 return downstream.cancellationRequested(); in cancellationRequested()
360 public boolean cancellationRequested() { in cancellationRequested() method in Sink.ChainedDouble
361 return downstream.cancellationRequested(); in cancellationRequested()
DSliceOps.java216 public boolean cancellationRequested() { in makeRef() method
217 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();
DFindOps.java185 public boolean cancellationRequested() { in cancellationRequested() method in FindOps.FindSink
DForEachOps.java288 while (!isShortCircuit || !taskSink.cancellationRequested()) { in compute()
DIntPipeline.java169 do { } while (!sink.cancellationRequested() && spl.tryAdvance(adaptedSink)); in forEachWithCancel()
DLongPipeline.java167 do { } while (!sink.cancellationRequested() && spl.tryAdvance(adaptedSink)); in forEachWithCancel()
DStreamSpliterators.java206 if (bufferSink.cancellationRequested() || !pusher.getAsBoolean()) {