Home
last modified time | relevance | path

Searched refs:Sink (Results 1 – 25 of 32) sorted by relevance

12

/libcore/ojluni/src/main/java/java/util/stream/
DSink.java119 public interface Sink<T> extends Consumer<T> { interface
191 interface OfInt extends Sink<Integer>, IntConsumer {
208 interface OfLong extends Sink<Long>, LongConsumer {
225 interface OfDouble extends Sink<Double>, DoubleConsumer {
246 static abstract class ChainedReference<T, E_OUT> implements Sink<T> {
247 protected final Sink<? super E_OUT> downstream;
249 public ChainedReference(Sink<? super E_OUT> downstream) { in ChainedReference()
278 static abstract class ChainedInt<E_OUT> implements Sink.OfInt {
279 protected final Sink<? super E_OUT> downstream;
281 public ChainedInt(Sink<? super E_OUT> downstream) { in ChainedInt()
[all …]
DIntPipeline.java100 private static IntConsumer adapt(Sink<Integer> sink) { in adapt()
166 public final void forEachWithCancel(Spliterator<Integer> spliterator, Sink<Integer> sink) { in forEachWithCancel()
199 public Sink<Integer> opWrapSink(int flags, Sink<Long> sink) { in asLongStream()
200 return new Sink.ChainedInt<Long>(sink) { in asLongStream()
216 public Sink<Integer> opWrapSink(int flags, Sink<Double> sink) {
217 return new Sink.ChainedInt<Double>(sink) {
239 public Sink<Integer> opWrapSink(int flags, Sink<Integer> sink) {
240 return new Sink.ChainedInt<Integer>(sink) {
257 public Sink<Integer> opWrapSink(int flags, Sink<U> sink) {
258 return new Sink.ChainedInt<U>(sink) {
[all …]
DLongPipeline.java100 private static LongConsumer adapt(Sink<Long> sink) { in adapt()
164 public final void forEachWithCancel(Spliterator<Long> spliterator, Sink<Long> sink) { in forEachWithCancel()
197 public Sink<Long> opWrapSink(int flags, Sink<Double> sink) { in asDoubleStream()
198 return new Sink.ChainedLong<Double>(sink) { in asDoubleStream()
220 public Sink<Long> opWrapSink(int flags, Sink<Long> sink) {
221 return new Sink.ChainedLong<Long>(sink) {
238 public Sink<Long> opWrapSink(int flags, Sink<U> sink) {
239 return new Sink.ChainedLong<U>(sink) {
256 public Sink<Long> opWrapSink(int flags, Sink<Integer> sink) {
257 return new Sink.ChainedLong<Integer>(sink) {
[all …]
DReferencePipeline.java132 public final void forEachWithCancel(Spliterator<P_OUT> spliterator, Sink<P_OUT> sink) { in forEachWithCancel()
162 public Sink<P_OUT> opWrapSink(int flags, Sink<P_OUT> sink) { in unordered()
175 public Sink<P_OUT> opWrapSink(int flags, Sink<P_OUT> sink) {
176 return new Sink.ChainedReference<P_OUT, P_OUT>(sink) {
199 public Sink<P_OUT> opWrapSink(int flags, Sink<R> sink) {
200 return new Sink.ChainedReference<P_OUT, R>(sink) {
217 public Sink<P_OUT> opWrapSink(int flags, Sink<Integer> sink) {
218 return new Sink.ChainedReference<P_OUT, Integer>(sink) {
235 public Sink<P_OUT> opWrapSink(int flags, Sink<Long> sink) {
236 return new Sink.ChainedReference<P_OUT, Long>(sink) {
[all …]
DDoublePipeline.java99 private static DoubleConsumer adapt(Sink<Double> sink) { in adapt()
163 public final void forEachWithCancel(Spliterator<Double> spliterator, Sink<Double> sink) { in forEachWithCancel()
202 public Sink<Double> opWrapSink(int flags, Sink<Double> sink) { in map()
203 return new Sink.ChainedDouble<Double>(sink) { in map()
220 public Sink<Double> opWrapSink(int flags, Sink<U> sink) {
221 return new Sink.ChainedDouble<U>(sink) {
238 public Sink<Double> opWrapSink(int flags, Sink<Integer> sink) {
239 return new Sink.ChainedDouble<Integer>(sink) {
256 public Sink<Double> opWrapSink(int flags, Sink<Long> sink) {
257 return new Sink.ChainedDouble<Long>(sink) {
[all …]
DPipelineHelper.java110 abstract<P_IN, S extends Sink<P_OUT>> S wrapAndCopyInto(S sink, Spliterator<P_IN> spliterator); in wrapAndCopyInto()
127 abstract<P_IN> void copyInto(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator); in copyInto()
143 abstract <P_IN> void copyIntoWithCancel(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator); in copyIntoWithCancel()
157 public abstract<P_IN> Sink<P_IN> wrapSink(Sink<P_OUT> sink); in wrapSink()
DSortedOps.java133 public Sink<T> opWrapSink(int flags, Sink<T> sink) { in opWrapSink()
174 public Sink<Integer> opWrapSink(int flags, Sink<Integer> sink) { in opWrapSink()
213 public Sink<Long> opWrapSink(int flags, Sink<Long> sink) { in opWrapSink()
252 public Sink<Double> opWrapSink(int flags, Sink<Double> sink) { in opWrapSink()
304 private static abstract class AbstractRefSortingSink<T> extends Sink.ChainedReference<T, T> {
309 AbstractRefSortingSink(Sink<? super T> downstream, Comparator<? super T> comparator) { in AbstractRefSortingSink()
334 SizedRefSortingSink(Sink<? super T> sink, Comparator<? super T> comparator) { in SizedRefSortingSink()
374 RefSortingSink(Sink<? super T> sink, Comparator<? super T> comparator) { in RefSortingSink()
411 private static abstract class AbstractIntSortingSink extends Sink.ChainedInt<Integer> {
414 AbstractIntSortingSink(Sink<? super Integer> downstream) { in AbstractIntSortingSink()
[all …]
DAbstractPipeline.java474 final <P_IN, S extends Sink<E_OUT>> S wrapAndCopyInto(S sink, Spliterator<P_IN> spliterator) { in wrapAndCopyInto()
480 final <P_IN> void copyInto(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator) { in copyInto()
495 final <P_IN> void copyIntoWithCancel(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator) { in copyIntoWithCancel()
519 public final <P_IN> Sink<P_IN> wrapSink(Sink<E_OUT> sink) { in wrapSink()
525 return (Sink<P_IN>) sink; in wrapSink()
617 public abstract void forEachWithCancel(Spliterator<E_OUT> spliterator, Sink<E_OUT> sink); in forEachWithCancel()
673 public abstract Sink<E_IN> opWrapSink(int flags, Sink<E_OUT> sink); in opWrapSink()
DForEachOps.java190 implements Sink.OfInt {
211 implements Sink.OfLong {
232 implements Sink.OfDouble {
256 private final Sink<S> sink;
262 Sink<S> sink) { in ForEachTask()
286 Sink<S> taskSink = sink; in compute()
369 private final Sink<T> action;
375 Sink<T> action) { in ForEachOrderedTask()
DSliceOps.java192 public Sink<T> opWrapSink(int flags, Sink<T> sink) { in makeRef()
193 return new Sink.ChainedReference<T, T>(sink) { in makeRef()
304 public Sink<Integer> opWrapSink(int flags, Sink<Integer> sink) {
305 return new Sink.ChainedInt<Integer>(sink) {
416 public Sink<Long> opWrapSink(int flags, Sink<Long> sink) {
417 return new Sink.ChainedLong<Long>(sink) {
528 public Sink<Double> opWrapSink(int flags, Sink<Double> sink) {
529 return new Sink.ChainedDouble<Double>(sink) {
617 Sink<P_OUT> opSink = op.opWrapSink(helper.getStreamAndOpFlags(), nb);
DDistinctOps.java122 public Sink<T> opWrapSink(int flags, Sink<T> sink) { in makeRef()
128 return new Sink.ChainedReference<T, T>(sink) { in makeRef()
159 return new Sink.ChainedReference<T, T>(sink) { in makeRef()
DMatchOps.java112 class MatchSink extends BooleanTerminalSink<Integer> implements Sink.OfInt { in makeInt()
141 class MatchSink extends BooleanTerminalSink<Long> implements Sink.OfLong { in makeLong()
171 class MatchSink extends BooleanTerminalSink<Double> implements Sink.OfDouble { in makeDouble()
252 private static abstract class BooleanTerminalSink<T> implements Sink<T> {
DReduceOps.java248 implements AccumulatingSink<Integer, Integer, ReducingSink>, Sink.OfInt {
290 implements AccumulatingSink<Integer, OptionalInt, ReducingSink>, Sink.OfInt {
348 implements AccumulatingSink<Integer, R, ReducingSink>, Sink.OfInt {
384 implements AccumulatingSink<Long, Long, ReducingSink>, Sink.OfLong {
426 implements AccumulatingSink<Long, OptionalLong, ReducingSink>, Sink.OfLong {
484 implements AccumulatingSink<Long, R, ReducingSink>, Sink.OfLong {
520 implements AccumulatingSink<Double, Double, ReducingSink>, Sink.OfDouble {
562 implements AccumulatingSink<Double, OptionalDouble, ReducingSink>, Sink.OfDouble {
620 implements AccumulatingSink<Double, R, ReducingSink>, Sink.OfDouble {
DTerminalSink.java38 interface TerminalSink<T, R> extends Sink<T>, Supplier<R> { }
DNode.java190 interface Builder<T> extends Sink<T> {
203 interface OfInt extends Node.Builder<Integer>, Sink.OfInt {
211 interface OfLong extends Node.Builder<Long>, Sink.OfLong {
219 interface OfDouble extends Node.Builder<Double>, Sink.OfDouble {
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DStatelessTestOp.java37 public Sink opWrapSink(int flags, Sink<T> sink) { in chain()
43 public Sink opWrapSink(int flags, Sink sink) { in chain()
50 public Sink opWrapSink(int flags, Sink sink) { in chain()
57 public Sink opWrapSink(int flags, Sink sink) { in chain()
71 Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_OUT> sink);
DStatefulTestOp.java40 public Sink opWrapSink(int flags, Sink sink) { in chain()
60 public Sink opWrapSink(int flags, Sink sink) { in chain()
80 public Sink opWrapSink(int flags, Sink sink) { in chain()
100 public Sink opWrapSink(int flags, Sink sink) { in chain()
127 Sink<E> opWrapSink(int flags, boolean parallel, Sink<E> sink);
DFlagDeclaringOp.java58 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { in opWrapSink()
DCollectorOps.java64 public Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_IN> sink) { in opWrapSink()
DTestFlagExpectedOp.java104 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { in opWrapSink()
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DStatelessTestOp.java31 import java.util.stream.Sink;
46 public Sink opWrapSink(int flags, Sink<T> sink) { in chain()
53 public Sink opWrapSink(int flags, Sink sink) { in chain()
60 public Sink opWrapSink(int flags, Sink sink) { in chain()
67 public Sink opWrapSink(int flags, Sink sink) { in chain()
81 Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_OUT> sink);
DStatefulTestOp.java41 public Sink opWrapSink(int flags, Sink sink) { in chain()
61 public Sink opWrapSink(int flags, Sink sink) { in chain()
81 public Sink opWrapSink(int flags, Sink sink) { in chain()
101 public Sink opWrapSink(int flags, Sink sink) { in chain()
128 Sink<E> opWrapSink(int flags, boolean parallel, Sink<E> sink);
DFlagDeclaringOp.java25 import java.util.stream.Sink;
61 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { in opWrapSink()
DCollectorOps.java65 public Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_IN> sink) { in opWrapSink()
DTestFlagExpectedOp.java105 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { in opWrapSink()

12