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