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.java118 public interface Sink<T> extends Consumer<T> { interface
190 interface OfInt extends Sink<Integer>, IntConsumer {
207 interface OfLong extends Sink<Long>, LongConsumer {
224 interface OfDouble extends Sink<Double>, DoubleConsumer {
245 static abstract class ChainedReference<T, E_OUT> implements Sink<T> {
246 protected final Sink<? super E_OUT> downstream;
248 public ChainedReference(Sink<? super E_OUT> downstream) { in ChainedReference()
277 static abstract class ChainedInt<E_OUT> implements Sink.OfInt {
278 protected final Sink<? super E_OUT> downstream;
280 public ChainedInt(Sink<? super E_OUT> downstream) { in ChainedInt()
[all …]
DIntPipeline.java99 private static IntConsumer adapt(Sink<Integer> sink) { in adapt()
160 public final void forEachWithCancel(Spliterator<Integer> spliterator, Sink<Integer> sink) { in forEachWithCancel()
192 public Sink<Integer> opWrapSink(int flags, Sink<Long> sink) { in asLongStream()
193 return new Sink.ChainedInt<Long>(sink) { in asLongStream()
208 public Sink<Integer> opWrapSink(int flags, Sink<Double> sink) {
209 return new Sink.ChainedInt<Double>(sink) {
230 public Sink<Integer> opWrapSink(int flags, Sink<Integer> sink) {
231 return new Sink.ChainedInt<Integer>(sink) {
247 public Sink<Integer> opWrapSink(int flags, Sink<U> sink) {
248 return new Sink.ChainedInt<U>(sink) {
[all …]
DLongPipeline.java99 private static LongConsumer adapt(Sink<Long> sink) { in adapt()
158 public final void forEachWithCancel(Spliterator<Long> spliterator, Sink<Long> sink) { in forEachWithCancel()
189 public Sink<Long> opWrapSink(int flags, Sink<Double> sink) { in asDoubleStream()
190 return new Sink.ChainedLong<Double>(sink) { in asDoubleStream()
211 public Sink<Long> opWrapSink(int flags, Sink<Long> sink) {
212 return new Sink.ChainedLong<Long>(sink) {
228 public Sink<Long> opWrapSink(int flags, Sink<U> sink) {
229 return new Sink.ChainedLong<U>(sink) {
245 public Sink<Long> opWrapSink(int flags, Sink<Integer> sink) {
246 return new Sink.ChainedLong<Integer>(sink) {
[all …]
DReferencePipeline.java126 public final void forEachWithCancel(Spliterator<P_OUT> spliterator, Sink<P_OUT> sink) { in forEachWithCancel()
154 public Sink<P_OUT> opWrapSink(int flags, Sink<P_OUT> sink) { in unordered()
166 public Sink<P_OUT> opWrapSink(int flags, Sink<P_OUT> sink) {
167 return new Sink.ChainedReference<P_OUT, P_OUT>(sink) {
190 public Sink<P_OUT> opWrapSink(int flags, Sink<R> sink) {
191 return new Sink.ChainedReference<P_OUT, R>(sink) {
207 public Sink<P_OUT> opWrapSink(int flags, Sink<Integer> sink) {
208 return new Sink.ChainedReference<P_OUT, Integer>(sink) {
224 public Sink<P_OUT> opWrapSink(int flags, Sink<Long> sink) {
225 return new Sink.ChainedReference<P_OUT, Long>(sink) {
[all …]
DDoublePipeline.java98 private static DoubleConsumer adapt(Sink<Double> sink) { in adapt()
157 public final void forEachWithCancel(Spliterator<Double> spliterator, Sink<Double> sink) { in forEachWithCancel()
194 public Sink<Double> opWrapSink(int flags, Sink<Double> sink) { in map()
195 return new Sink.ChainedDouble<Double>(sink) { in map()
211 public Sink<Double> opWrapSink(int flags, Sink<U> sink) {
212 return new Sink.ChainedDouble<U>(sink) {
228 public Sink<Double> opWrapSink(int flags, Sink<Integer> sink) {
229 return new Sink.ChainedDouble<Integer>(sink) {
245 public Sink<Double> opWrapSink(int flags, Sink<Long> sink) {
246 return new Sink.ChainedDouble<Long>(sink) {
[all …]
DPipelineHelper.java108 abstract<P_IN, S extends Sink<P_OUT>> S wrapAndCopyInto(S sink, Spliterator<P_IN> spliterator); in wrapAndCopyInto()
125 abstract<P_IN> void copyInto(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator); in copyInto()
141 abstract <P_IN> void copyIntoWithCancel(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator); in copyIntoWithCancel()
154 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.java471 final <P_IN, S extends Sink<E_OUT>> S wrapAndCopyInto(S sink, Spliterator<P_IN> spliterator) { in wrapAndCopyInto()
477 final <P_IN> void copyInto(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator) { in copyInto()
492 final <P_IN> void copyIntoWithCancel(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator) { in copyIntoWithCancel()
514 public final <P_IN> Sink<P_IN> wrapSink(Sink<E_OUT> sink) { in wrapSink()
520 return (Sink<P_IN>) sink; in wrapSink()
606 public abstract void forEachWithCancel(Spliterator<E_OUT> spliterator, Sink<E_OUT> sink); in forEachWithCancel()
659 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.java119 public Sink<T> opWrapSink(int flags, Sink<T> sink) { in makeRef()
125 return new Sink.ChainedReference<T, T>(sink) { in makeRef()
156 return new Sink.ChainedReference<T, T>(sink) { in makeRef()
DSliceOps.java189 public Sink<T> opWrapSink(int flags, Sink<T> sink) { in makeRef()
190 return new Sink.ChainedReference<T, T>(sink) { in makeRef()
298 public Sink<Integer> opWrapSink(int flags, Sink<Integer> sink) {
299 return new Sink.ChainedInt<Integer>(sink) {
407 public Sink<Long> opWrapSink(int flags, Sink<Long> sink) {
408 return new Sink.ChainedLong<Long>(sink) {
516 public Sink<Double> opWrapSink(int flags, Sink<Double> sink) {
517 return new Sink.ChainedDouble<Double>(sink) {
605 Sink<P_OUT> opSink = op.opWrapSink(helper.getStreamAndOpFlags(), nb);
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> {
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.java189 interface Builder<T> extends Sink<T> {
202 interface OfInt extends Node.Builder<Integer>, Sink.OfInt {
210 interface OfLong extends Node.Builder<Long>, Sink.OfLong {
218 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