Searched refs:wrapSink (Results 1 – 5 of 5) sorted by relevance
157 public abstract<P_IN> Sink<P_IN> wrapSink(Sink<P_OUT> sink); in wrapSink() method in PipelineHelper
475 copyInto(wrapSink(Objects.requireNonNull(sink)), spliterator); in wrapAndCopyInto()519 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()
618 helper.copyIntoWithCancel(helper.wrapSink(opSink), spliterator);