Home
last modified time | relevance | path

Searched refs:R (Results 1 – 25 of 76) sorted by relevance

1234

/libcore/ojluni/src/main/java/java/util/stream/
DReduceOps.java204 public static <T, R> TerminalOp<T, R>
205 makeRef(Supplier<R> seedFactory,
206 BiConsumer<R, ? super T> accumulator,
207 BiConsumer<R,R> reducer) {
211 class ReducingSink extends Box<R>
212 implements AccumulatingSink<T, R, ReducingSink> {
228 return new ReduceOp<T, R, ReducingSink>(StreamShape.REFERENCE) {
340 public static <R> TerminalOp<Integer, R>
341 makeInt(Supplier<R> supplier,
342 ObjIntConsumer<R> accumulator,
[all …]
DCollector.java197 public interface Collector<T, A, R> {
233 Function<A, R> finisher(); in finisher()
260 public static<T, R> Collector<T, R, R> of(Supplier<R> supplier, in of()
261 BiConsumer<R, T> accumulator, in of() argument
262 BinaryOperator<R> combiner, in of()
291 public static<T, A, R> Collector<T, A, R> of(Supplier<A> supplier, in of()
294 Function<A, R> finisher, in of()
DAbstractShortCircuitTask.java43 abstract class AbstractShortCircuitTask<P_IN, P_OUT, R,
44 K extends AbstractShortCircuitTask<P_IN, P_OUT, R, K>>
45 extends AbstractTask<P_IN, P_OUT, R, K> {
50 protected final AtomicReference<R> sharedResult;
94 protected abstract R getEmptyResult(); in getEmptyResult()
107 AtomicReference<R> sr = sharedResult; in compute()
108 R result; in compute()
150 protected void shortCircuit(R result) { in shortCircuit()
162 protected void setLocalResult(R localResult) { in setLocalResult()
175 public R getRawResult() { in getRawResult()
[all …]
DAbstractTask.java87 abstract class AbstractTask<P_IN, P_OUT, R,
88 K extends AbstractTask<P_IN, P_OUT, R, K>>
89 extends CountedCompleter<R> {
126 private R localResult;
176 protected abstract R doLeaf(); in doLeaf()
208 public R getRawResult() { in getRawResult()
221 protected void setRawResult(R result) { in setRawResult()
232 protected R getLocalResult() { in getLocalResult()
242 protected void setLocalResult(R localResult) { in setLocalResult()
DStream.java184 <R> Stream<R> map(Function<? super T, ? extends R> mapper); in map()
270 <R> Stream<R> flatMap(Function<? super T, ? extends Stream<? extends R>> mapper); in flatMap()
751 <R> R collect(Supplier<R> supplier, in collect()
752 BiConsumer<R, ? super T> accumulator, in collect() argument
753 BiConsumer<R, R> combiner); in collect()
807 <R, A> R collect(Collector<? super T, A, R> collector); in collect()
DReferencePipeline.java194 public final <R> Stream<R> map(Function<? super P_OUT, ? extends R> mapper) {
196 return new StatelessOp<P_OUT, R>(this, StreamShape.REFERENCE,
199 public Sink<P_OUT> opWrapSink(int flags, Sink<R> sink) {
200 return new Sink.ChainedReference<P_OUT, R>(sink) {
265 …public final <R> Stream<R> flatMap(Function<? super P_OUT, ? extends Stream<? extends R>> mapper) {
268 return new StatelessOp<P_OUT, R>(this, StreamShape.REFERENCE,
271 public Sink<P_OUT> opWrapSink(int flags, Sink<R> sink) {
272 return new Sink.ChainedReference<P_OUT, R>(sink) {
280 try (Stream<? extends R> result = mapper.apply(u)) {
501 …public final <R> R reduce(R identity, BiFunction<R, ? super P_OUT, R> accumulator, BinaryOperator<…
[all …]
DTerminalOp.java45 interface TerminalOp<E_IN, R> {
80 default <P_IN> R evaluateParallel(PipelineHelper<E_IN> helper, in evaluateParallel()
96 <P_IN> R evaluateSequential(PipelineHelper<E_IN> helper, in evaluateSequential()
DTerminalSink.java38 interface TerminalSink<T, R> extends Sink<T>, Supplier<R> { }
/libcore/ojluni/src/main/java/java/util/function/
DFunction.java41 public interface Function<T, R> {
49 R apply(T t); in apply()
66 default <V> Function<V, R> compose(Function<? super V, ? extends T> before) { in compose()
86 default <V> Function<T, V> andThen(Function<? super R, ? extends V> after) { in andThen() argument
DBiFunction.java44 public interface BiFunction<T, U, R> {
53 R apply(T t, U u); in apply()
68 default <V> BiFunction<T, U, V> andThen(Function<? super R, ? extends V> after) { in andThen() argument
DIntFunction.java41 public interface IntFunction<R> {
49 R apply(int value); in apply()
DLongFunction.java41 public interface LongFunction<R> {
49 R apply(long value); in apply()
DDoubleFunction.java41 public interface DoubleFunction<R> {
49 R apply(double value); in apply()
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DOpTestCase.java76 public interface ResultAsserter<R> {
86 void assertResult(R actual, R expected, boolean isOrdered, boolean isParallel); in assertResult()
145 protected final<T, U, R, S_IN extends BaseStream<T, S_IN>, S_OUT extends BaseStream<U, S_OUT>>
147 R expected, in exerciseTerminalOpsMulti()
149 Map<String, Function<S_OUT, R>> terminals) { in exerciseTerminalOpsMulti()
152 for (Map.Entry<String, Function<S_OUT, R>> te : terminals.entrySet()) { in exerciseTerminalOpsMulti()
237 public <R> ExerciseDataTerminalBuilder<T, T, R, S_IN, S_IN>
238 terminal(Function<S_IN, R> terminalF) { in terminal()
242 …public <U, R, S_OUT extends BaseStream<U, S_OUT>> ExerciseDataTerminalBuilder<T, U, R, S_IN, S_OUT>
243 terminal(Function<S_IN, S_OUT> streamF, Function<S_OUT, R> terminalF) { in terminal()
[all …]
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DOpTestCase.java75 public interface ResultAsserter<R> {
85 void assertResult(R actual, R expected, boolean isOrdered, boolean isParallel); in assertResult()
144 protected final<T, U, R, S_IN extends BaseStream<T, S_IN>, S_OUT extends BaseStream<U, S_OUT>>
146 R expected, in exerciseTerminalOpsMulti()
148 Map<String, Function<S_OUT, R>> terminals) { in exerciseTerminalOpsMulti()
151 for (Map.Entry<String, Function<S_OUT, R>> te : terminals.entrySet()) { in exerciseTerminalOpsMulti()
236 public <R> ExerciseDataTerminalBuilder<T, T, R, S_IN, S_IN>
237 terminal(Function<S_IN, R> terminalF) { in terminal()
241 …public <U, R, S_OUT extends BaseStream<U, S_OUT>> ExerciseDataTerminalBuilder<T, U, R, S_IN, S_OUT>
242 terminal(Function<S_IN, S_OUT> streamF, Function<S_OUT, R> terminalF) { in terminal()
[all …]
/libcore/ojluni/src/main/java/java/time/temporal/
DIsoFields.java336 public <R extends Temporal> R adjustInto(R temporal, long newValue) { in adjustInto()
340 … return (R) temporal.with(DAY_OF_YEAR, temporal.getLong(DAY_OF_YEAR) + (newValue - curValue)); in adjustInto()
406 public <R extends Temporal> R adjustInto(R temporal, long newValue) { in adjustInto()
410 …return (R) temporal.with(MONTH_OF_YEAR, temporal.getLong(MONTH_OF_YEAR) + (newValue - curValue) * … in adjustInto()
461 public <R extends Temporal> R adjustInto(R temporal, long newValue) { in adjustInto()
464 return (R) temporal.plus(Math.subtractExact(newValue, getFrom(temporal)), WEEKS); in adjustInto()
535 public <R extends Temporal> R adjustInto(R temporal, long newValue) { in adjustInto()
549 return (R) temporal.with(resolved); in adjustInto()
690 public <R extends Temporal> R addTo(R temporal, long amount) { in addTo()
693 return (R) temporal.with(WEEK_BASED_YEAR, in addTo()
[all …]
DChronoUnit.java265 public <R extends Temporal> R addTo(R temporal, long amount) { in addTo()
266 return (R) temporal.plus(amount, this); in addTo()
DTemporalField.java306 <R extends Temporal> R adjustInto(R temporal, long newValue); in adjustInto()
DTemporalUnit.java227 <R extends Temporal> R addTo(R temporal, long amount); in addTo()
DTemporalAccessor.java308 default <R> R query(TemporalQuery<R> query) { in query()
DTemporalQuery.java103 public interface TemporalQuery<R> {
143 R queryFrom(TemporalAccessor temporal); in queryFrom()
/libcore/ojluni/src/main/java/java/time/format/
DDateTimePrintContext.java209 public <R> R query(TemporalQuery<R> query) { in adjust()
211 return (R) effectiveChrono; in adjust()
214 return (R) effectiveZone; in adjust()
279 <R> R getValue(TemporalQuery<R> query) {
280 R result = temporal.query(query);
/libcore/ojluni/src/main/java/java/time/chrono/
DEra.java268 default <R> R query(TemporalQuery<R> query) { in query()
270 return (R) ERAS; in query()
/libcore/ojluni/src/test/java/time/tck/java/time/chrono/
DTCKIsoChronology.java111 public <R> R query(TemporalQuery<R> query) { in factory_from_TemporalAccessor_chronology()
113 return (R) IsoChronology.INSTANCE; in factory_from_TemporalAccessor_chronology()
134 public <R> R query(TemporalQuery<R> query) { in factory_from_TemporalAccessor_noChronology()
170 public <R> R query(TemporalQuery<R> query) { in test_date_TemporalAccessor()
172 return (R) LocalDate.of(2012, 6, 30); in test_date_TemporalAccessor()
209 public <R> R query(TemporalQuery<R> query) { in test_localDateTime_TemporalAccessor()
211 return (R) LocalDate.of(2012, 6, 30); in test_localDateTime_TemporalAccessor()
214 return (R) LocalTime.of(12, 30, 40); in test_localDateTime_TemporalAccessor()
258 public <R> R query(TemporalQuery<R> query) { in test_zonedDateTime_TemporalAccessor()
260 return (R) LocalDate.of(2012, 6, 30); in test_zonedDateTime_TemporalAccessor()
[all …]
/libcore/ojluni/src/test/java/time/test/java/time/temporal/
DMockFieldNoValue.java121 public <R extends Temporal> R adjustInto(R temporal, long newValue) { in adjustInto()

1234