Home
last modified time | relevance | path

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

12345

/libcore/ojluni/src/main/java/java/util/stream/
DCollector.java201 public interface Collector<T, A, R> {
237 Function<A, R> finisher(); in finisher()
264 public static<T, R> Collector<T, R, R> of(Supplier<R> supplier, in of()
265 BiConsumer<R, T> accumulator, in of() argument
266 BinaryOperator<R> combiner, in of()
295 public static<T, A, R> Collector<T, A, R> of(Supplier<A> supplier, in of()
298 Function<A, R> finisher, in of()
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) {
381 public static <R> TerminalOp<Integer, R>
382 makeInt(Supplier<R> supplier,
383 ObjIntConsumer<R> accumulator,
[all …]
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.java88 abstract class AbstractTask<P_IN, P_OUT, R,
89 K extends AbstractTask<P_IN, P_OUT, R, K>>
90 extends CountedCompleter<R> {
121 private R localResult;
187 protected abstract R doLeaf(); in doLeaf()
219 public R getRawResult() { in getRawResult()
232 protected void setRawResult(R result) { in setRawResult()
243 protected R getLocalResult() { in getLocalResult()
253 protected void setLocalResult(R localResult) { in setLocalResult()
DStream.java194 <R> Stream<R> map(Function<? super T, ? extends R> mapper); in map()
281 <R> Stream<R> flatMap(Function<? super T, ? extends Stream<? extends R>> mapper); in flatMap()
426 default <R> Stream<R> mapMulti(BiConsumer<? super T, ? super Consumer<R>> mapper) { in mapMulti()
429 SpinedBuffer<R> buffer = new SpinedBuffer<>(); in mapMulti()
1109 <R> R collect(Supplier<R> supplier,
1110 BiConsumer<R, ? super T> accumulator,
1111 BiConsumer<R, R> combiner);
1165 <R, A> R collect(Collector<? super T, A, R> collector);
DReferencePipeline.java200 public final <R> Stream<R> map(Function<? super P_OUT, ? extends R> mapper) {
202 return new StatelessOp<P_OUT, R>(this, StreamShape.REFERENCE,
205 public Sink<P_OUT> opWrapSink(int flags, Sink<R> sink) {
206 return new Sink.ChainedReference<P_OUT, R>(sink) {
271 …public final <R> Stream<R> flatMap(Function<? super P_OUT, ? extends Stream<? extends R>> mapper) {
273 return new StatelessOp<P_OUT, R>(this, StreamShape.REFERENCE,
276 public Sink<P_OUT> opWrapSink(int flags, Sink<R> sink) {
288 try (Stream<? extends R> result = mapper.apply(u)) {
452 public final <R> Stream<R> mapMulti(BiConsumer<? super P_OUT, ? super Consumer<R>> mapper) {
458 public Sink<P_OUT> opWrapSink(int flags, Sink<R> sink) {
[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()
/libcore/ojluni/src/tools/make/gensrc/
DGensrcBuffer.gmk43 ifeq (R, $2)
296 $(eval $(call SetupGenBuffer,HeapByteBufferR, $(HEAP_X_BUF), type:=byte, RW:=R))
298 $(eval $(call SetupGenBuffer,HeapCharBufferR, $(HEAP_X_BUF), type:=char, RW:=R))
300 $(eval $(call SetupGenBuffer,HeapShortBufferR, $(HEAP_X_BUF), type:=short, RW:=R))
302 $(eval $(call SetupGenBuffer,HeapIntBufferR, $(HEAP_X_BUF), type:=int, RW:=R))
304 $(eval $(call SetupGenBuffer,HeapLongBufferR, $(HEAP_X_BUF), type:=long, RW:=R))
306 $(eval $(call SetupGenBuffer,HeapFloatBufferR, $(HEAP_X_BUF), type:=float, RW:=R))
308 $(eval $(call SetupGenBuffer,HeapDoubleBufferR,$(HEAP_X_BUF), type:=double, RW:=R))
315 $(eval $(call SetupGenBuffer,DirectByteBufferR,$(DIRECT_X_BUF), type:=byte, BIN:=1, RW:=R))
320 $(eval $(call SetupGenBuffer,DirectCharBufferRU, $(DIRECT_X_BUF), type:=char, RW:=R, BO:=U))
[all …]
/libcore/ojluni/src/test/java/io/Serializable/records/
DCycleTest.java46 record R (int x, int y, C c) implements Serializable { }
60 R r = new R(1, 2, c); in testCycle1()
64 R deserializedObj = serializeDeserialize(r); in testCycle1()
81 R r = new R(3, 4, c); in testCycle2()
89 assertEquals(((R)deserializedObj.obj).x(), 3); // sanity in testCycle2()
90 assertEquals(((R)deserializedObj.obj).y(), 4); // sanity in testCycle2()
119 record R3 (long l, R r) implements Serializable { }
129 R r = new R(7, 8, c); in testCycle4()
/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/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 …]
DDefaultMethodStreams.java192 public <R> Stream<R> map(Function<? super T, ? extends R> mapper) { in map()
212 public <R> Stream<R> flatMap(Function<? super T, ? extends Stream<? extends R>> mapper) { in flatMap()
297 …public <R> R collect(Supplier<R> supplier, BiConsumer<R, ? super T> accumulator, BiConsumer<R, R> … in collect() argument
302 public <R, A> R collect(Collector<? super T, A, R> collector) { in collect()
478 …public <R> R collect(Supplier<R> supplier, ObjIntConsumer<R> accumulator, BiConsumer<R, R> combine… in collect() argument
684 …public <R> R collect(Supplier<R> supplier, ObjLongConsumer<R> accumulator, BiConsumer<R, R> combin… in collect() argument
882 …public <R> R collect(Supplier<R> supplier, ObjDoubleConsumer<R> accumulator, BiConsumer<R, R> comb… in collect() argument
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DCollectorExample.java65 <T, A, R> void testSnippet1(Collector<T, A, R> collector, T t1, T t2) { in testSnippet1()
70 Function<A, R> finisher = collector.finisher(); in testSnippet1()
76 R r1 = finisher.apply(a1); in testSnippet1()
82 R r2 = finisher.apply(combiner.apply(a2, a3)); in testSnippet1()
91 <T, A, R> void testSnippet3(Collector<T, A, R> collector, Collection<T> data) { in testSnippet3()
/libcore/ojluni/src/main/java/java/time/temporal/
DIsoFields.java343 public <R extends Temporal> R adjustInto(R temporal, long newValue) { in adjustInto()
347 … return (R) temporal.with(DAY_OF_YEAR, temporal.getLong(DAY_OF_YEAR) + (newValue - curValue)); in adjustInto()
419 public <R extends Temporal> R adjustInto(R temporal, long newValue) { in adjustInto()
423 …return (R) temporal.with(MONTH_OF_YEAR, temporal.getLong(MONTH_OF_YEAR) + (newValue - curValue) * … in adjustInto()
483 public <R extends Temporal> R adjustInto(R temporal, long newValue) { in adjustInto()
486 return (R) temporal.plus(Math.subtractExact(newValue, getFrom(temporal)), WEEKS); in adjustInto()
563 public <R extends Temporal> R adjustInto(R temporal, long newValue) { in adjustInto()
577 return (R) temporal.with(resolved); in adjustInto()
715 public <R extends Temporal> R addTo(R temporal, long amount) { in addTo()
718 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()
DTemporalUnit.java227 <R extends Temporal> R addTo(R temporal, long amount); in addTo()
DTemporalField.java306 <R extends Temporal> R adjustInto(R temporal, long newValue); in adjustInto()
DTemporalAccessor.java308 default <R> R query(TemporalQuery<R> query) { in query()
/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
/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()
286 <R> R getValue(TemporalQuery<R> query) {
287 R result = temporal.query(query);
/libcore/ojluni/src/test/java/lang/String/
DSplit.java43 private static Random R; field in Split
47 R = new Random(); in setUp()
141 testSplit_fastPath_(FAST_PATH_SOURCE, R, false, 0, 0x11000);
147 testSplit_fastPath_(FAST_PATH_SOURCE, R, true, shardRange[0], shardRange[1]);
153 testSplit_fastPath_(FAST_PATH_SOURCE, R, true, shardRange[0], shardRange[1]);
159 testSplit_fastPath_(FAST_PATH_SOURCE, R, true, shardRange[0], shardRange[1]);
165 testSplit_fastPath_(FAST_PATH_SOURCE, R, true, shardRange[0], shardRange[1]);
/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()
DChronoZonedDateTime.java490 default <R> R query(TemporalQuery<R> query) { in query()
492 return (R) getZone(); in query()
494 return (R) getOffset(); in query()
496 return (R) toLocalTime(); in query()
498 return (R) getChronology(); in query()
500 return (R) NANOS; in query()
/libcore/ojluni/src/test/java/time/tck/java/time/chrono/
DTCKIsoChronology.java119 public <R> R query(TemporalQuery<R> query) { in factory_from_TemporalAccessor_chronology()
121 return (R) IsoChronology.INSTANCE; in factory_from_TemporalAccessor_chronology()
142 public <R> R query(TemporalQuery<R> query) { in factory_from_TemporalAccessor_noChronology()
178 public <R> R query(TemporalQuery<R> query) { in test_date_TemporalAccessor()
180 return (R) LocalDate.of(2012, 6, 30); in test_date_TemporalAccessor()
217 public <R> R query(TemporalQuery<R> query) { in test_localDateTime_TemporalAccessor()
219 return (R) LocalDate.of(2012, 6, 30); in test_localDateTime_TemporalAccessor()
222 return (R) LocalTime.of(12, 30, 40); in test_localDateTime_TemporalAccessor()
266 public <R> R query(TemporalQuery<R> query) { in test_zonedDateTime_TemporalAccessor()
268 return (R) LocalDate.of(2012, 6, 30); in test_zonedDateTime_TemporalAccessor()
[all …]

12345