Home
last modified time | relevance | path

Searched refs:Sink (Results 1 – 25 of 28) 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 …]
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()
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()
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()
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);
DTerminalSink.java38 interface TerminalSink<T, R> extends Sink<T>, Supplier<R> { }
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 {
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 {
DFindOps.java199 implements Sink.OfInt {
214 implements Sink.OfLong {
229 implements Sink.OfDouble {
DStreamSpliterators.java90 Sink<P_IN> bufferSink;
312 ph.wrapAndCopyInto((Sink<P_OUT>) consumer::accept, spliterator); in forEachRemaining()
346 bufferSink = ph.wrapSink((Sink.OfInt) b::accept); in initPartialTraversalState()
370 ph.wrapAndCopyInto((Sink.OfInt) consumer::accept, spliterator); in forEachRemaining()
404 bufferSink = ph.wrapSink((Sink.OfLong) b::accept); in initPartialTraversalState()
428 ph.wrapAndCopyInto((Sink.OfLong) consumer::accept, spliterator); in forEachRemaining()
462 bufferSink = ph.wrapSink((Sink.OfDouble) b::accept); in initPartialTraversalState()
486 ph.wrapAndCopyInto((Sink.OfDouble) consumer::accept, spliterator); in forEachRemaining()
DNodes.java1822 private static abstract class SizedCollectorTask<P_IN, P_OUT, T_SINK extends Sink<P_OUT>,
1825 implements Sink<P_OUT> {
1897 extends SizedCollectorTask<P_IN, P_OUT, Sink<P_OUT>, OfRef<P_IN, P_OUT>>
1898 implements Sink<P_OUT> {
1929 extends SizedCollectorTask<P_IN, Integer, Sink.OfInt, OfInt<P_IN>>
1930 implements Sink.OfInt {
1961 extends SizedCollectorTask<P_IN, Long, Sink.OfLong, OfLong<P_IN>>
1962 implements Sink.OfLong {
1993 extends SizedCollectorTask<P_IN, Double, Sink.OfDouble, OfDouble<P_IN>>
1994 implements 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()
/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/
DFlagOpTest.java71 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { in opWrapSink()
264 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { in opWrapSink()

12