Lines Matching defs:downstream
290 * sorted and then pushed downstream.
294 * pushing elements downstream will preserve the short-circuiting protocol
295 * by calling {@code downstream.cancellationRequested()} and checking the
309 AbstractRefSortingSink(Sink<? super T> downstream, Comparator<? super T> comparator) {
310 super(downstream);
316 * can be preserved when the sorted elements are pushed downstream.
349 downstream.begin(offset);
352 downstream.accept(array[i]);
355 for (int i = 0; i < offset && !downstream.cancellationRequested(); i++)
356 downstream.accept(array[i]);
358 downstream.end();
388 downstream.begin(list.size());
390 list.forEach(downstream::accept);
394 if (downstream.cancellationRequested()) break;
395 downstream.accept(t);
398 downstream.end();
414 AbstractIntSortingSink(Sink<? super Integer> downstream) {
415 super(downstream);
432 SizedIntSortingSink(Sink<? super Integer> downstream) {
433 super(downstream);
446 downstream.begin(offset);
449 downstream.accept(array[i]);
452 for (int i = 0; i < offset && !downstream.cancellationRequested(); i++)
453 downstream.accept(array[i]);
455 downstream.end();
486 downstream.begin(ints.length);
489 downstream.accept(anInt);
493 if (downstream.cancellationRequested()) break;
494 downstream.accept(anInt);
497 downstream.end();
512 AbstractLongSortingSink(Sink<? super Long> downstream) {
513 super(downstream);
530 SizedLongSortingSink(Sink<? super Long> downstream) {
531 super(downstream);
544 downstream.begin(offset);
547 downstream.accept(array[i]);
550 for (int i = 0; i < offset && !downstream.cancellationRequested(); i++)
551 downstream.accept(array[i]);
553 downstream.end();
584 downstream.begin(longs.length);
587 downstream.accept(aLong);
591 if (downstream.cancellationRequested()) break;
592 downstream.accept(aLong);
595 downstream.end();
610 AbstractDoubleSortingSink(Sink<? super Double> downstream) {
611 super(downstream);
628 SizedDoubleSortingSink(Sink<? super Double> downstream) {
629 super(downstream);
642 downstream.begin(offset);
645 downstream.accept(array[i]);
648 for (int i = 0; i < offset && !downstream.cancellationRequested(); i++)
649 downstream.accept(array[i]);
651 downstream.end();
682 downstream.begin(doubles.length);
685 downstream.accept(aDouble);
689 if (downstream.cancellationRequested()) break;
690 downstream.accept(aDouble);
693 downstream.end();
