Searched refs:wrapSink (Results 1 – 5 of 5) sorted by relevance
154 public abstract<P_IN> Sink<P_IN> wrapSink(Sink<P_OUT> sink); in wrapSink() method in PipelineHelper
472 copyInto(wrapSink(Objects.requireNonNull(sink)), spliterator); in wrapAndCopyInto()514 public final <P_IN> Sink<P_IN> wrapSink(Sink<E_OUT> sink) { in wrapSink() method in AbstractPipeline
293 bufferSink = ph.wrapSink(b::accept);346 bufferSink = ph.wrapSink((Sink.OfInt) b::accept); in initPartialTraversalState()404 bufferSink = ph.wrapSink((Sink.OfLong) b::accept); in initPartialTraversalState()462 bufferSink = ph.wrapSink((Sink.OfDouble) b::accept); in initPartialTraversalState()
160 new ForEachTask<>(helper, spliterator, helper.wrapSink(this)).invoke(); in evaluateParallel()
606 helper.copyIntoWithCancel(helper.wrapSink(opSink), spliterator);