Searched refs:adaptedSink (Results 1 – 3 of 3) sorted by relevance
168 IntConsumer adaptedSink = adapt(sink); in forEachWithCancel() local170 do { } while (!(cancelled = sink.cancellationRequested()) && spl.tryAdvance(adaptedSink)); in forEachWithCancel()
166 LongConsumer adaptedSink = adapt(sink); in forEachWithCancel() local168 do { } while (!(cancelled = sink.cancellationRequested()) && spl.tryAdvance(adaptedSink)); in forEachWithCancel()
165 DoubleConsumer adaptedSink = adapt(sink); in forEachWithCancel() local167 do { } while (!(cancelled = sink.cancellationRequested()) && spl.tryAdvance(adaptedSink)); in forEachWithCancel()