HomeSort by relevance Sort by last modified time
    Searched refs:cancellationRequested (Results 1 - 11 of 11) sorted by null

  /libcore/ojluni/src/main/java/java/util/stream/
Sink.java 43 * not wish to receive any more data (the {@code cancellationRequested()}
94 * {@code begin()}, {@code end()}, and {@code cancellationRequested()} to
148 default boolean cancellationRequested() {
239 * {@code cancellationRequested} methods are wired to chain to the
263 public boolean cancellationRequested() {
264 return downstream.cancellationRequested();
271 * {@code cancellationRequested} methods are wired to chain to the
295 public boolean cancellationRequested() {
296 return downstream.cancellationRequested();
303 * {@code cancellationRequested} methods are wired to chain to th
    [all...]
SortedOps.java 291 * This class records if {@link #cancellationRequested} is called. If so it
295 * by calling {@code downstream.cancellationRequested()} and checking the
321 public final boolean cancellationRequested() {
355 for (int i = 0; i < offset && !downstream.cancellationRequested(); i++)
394 if (downstream.cancellationRequested()) break;
419 public final boolean cancellationRequested() {
452 for (int i = 0; i < offset && !downstream.cancellationRequested(); i++)
493 if (downstream.cancellationRequested()) break;
517 public final boolean cancellationRequested() {
550 for (int i = 0; i < offset && !downstream.cancellationRequested(); i++
    [all...]
SliceOps.java 213 public boolean cancellationRequested() {
214 return m == 0 || downstream.cancellationRequested();
322 public boolean cancellationRequested() {
323 return m == 0 || downstream.cancellationRequested();
431 public boolean cancellationRequested() {
432 return m == 0 || downstream.cancellationRequested();
540 public boolean cancellationRequested() {
541 return m == 0 || downstream.cancellationRequested();
    [all...]
FindOps.java 185 public boolean cancellationRequested() {
MatchOps.java 265 public boolean cancellationRequested() {
ForEachOps.java 288 while (!isShortCircuit || !taskSink.cancellationRequested()) {
DoublePipeline.java 160 do { } while (!sink.cancellationRequested() && spl.tryAdvance(adaptedSink));
LongPipeline.java 161 do { } while (!sink.cancellationRequested() && spl.tryAdvance(adaptedSink));
IntPipeline.java 163 do { } while (!sink.cancellationRequested() && spl.tryAdvance(adaptedSink));
ReferencePipeline.java 127 do { } while (!sink.cancellationRequested() && spliterator.tryAdvance(sink));
255 // We can do better than this, by polling cancellationRequested when stream is infinite
282 // We can do better than this, by polling cancellationRequested when stream is infinite
310 // We can do better than this, by polling cancellationRequested when stream is infinite
338 // We can do better than this, by polling cancellationRequested when stream is infinite
StreamSpliterators.java 206 if (bufferSink.cancellationRequested() || !pusher.getAsBoolean()) {
    [all...]

Completed in 968 milliseconds