Home
last modified time | relevance | path

Searched refs:supplier (Results 1 – 24 of 24) sorted by relevance

/libcore/ojluni/src/main/java/java/util/stream/
DStreamSupport.java107 public static <T> Stream<T> stream(Supplier<? extends Spliterator<T>> supplier, in stream() argument
110 Objects.requireNonNull(supplier); in stream()
111 return new ReferencePipeline.Head<>(supplier, in stream()
175 public static IntStream intStream(Supplier<? extends Spliterator.OfInt> supplier, in intStream() argument
178 return new IntPipeline.Head<>(supplier, in intStream()
243 public static LongStream longStream(Supplier<? extends Spliterator.OfLong> supplier, in longStream() argument
246 return new LongPipeline.Head<>(supplier, in longStream()
311 public static DoubleStream doubleStream(Supplier<? extends Spliterator.OfDouble> supplier, in doubleStream() argument
314 return new DoublePipeline.Head<>(supplier, in doubleStream()
DCollector.java203 Supplier<A> supplier(); in supplier() method
260 public static<T, R> Collector<T, R, R> of(Supplier<R> supplier, in of() argument
264 Objects.requireNonNull(supplier); in of()
272 return new Collectors.CollectorImpl<>(supplier, accumulator, combiner, cs); in of()
291 public static<T, A, R> Collector<T, A, R> of(Supplier<A> supplier, in of() argument
296 Objects.requireNonNull(supplier); in of()
307 return new Collectors.CollectorImpl<>(supplier, accumulator, combiner, finisher, cs); in of()
DReduceOps.java157 Supplier<I> supplier = Objects.requireNonNull(collector).supplier();
164 state = supplier.get();
341 makeInt(Supplier<R> supplier,
344 Objects.requireNonNull(supplier);
351 state = supplier.get();
477 makeLong(Supplier<R> supplier,
480 Objects.requireNonNull(supplier);
487 state = supplier.get();
613 makeDouble(Supplier<R> supplier,
616 Objects.requireNonNull(supplier);
[all …]
DStreamSpliterators.java273 Supplier<Spliterator<P_IN>> supplier,
275 super(ph, supplier, parallel);
326 Supplier<Spliterator<P_IN>> supplier, in IntWrappingSpliterator() argument
328 super(ph, supplier, parallel); in IntWrappingSpliterator()
384 Supplier<Spliterator<P_IN>> supplier, in LongWrappingSpliterator() argument
386 super(ph, supplier, parallel); in LongWrappingSpliterator()
442 Supplier<Spliterator<P_IN>> supplier, in DoubleWrappingSpliterator() argument
444 super(ph, supplier, parallel); in DoubleWrappingSpliterator()
503 private final Supplier<? extends T_SPLITR> supplier; field in StreamSpliterators.AbstractWrappingSpliterator.DelegatingSpliterator
507 DelegatingSpliterator(Supplier<? extends T_SPLITR> supplier) { in DelegatingSpliterator() argument
[all …]
DCollectors.java148 private final Supplier<A> supplier; field in CollectorImpl
154 CollectorImpl(Supplier<A> supplier, in CollectorImpl() argument
159 this.supplier = supplier; in CollectorImpl()
166 CollectorImpl(Supplier<A> supplier, in CollectorImpl() argument
170 this(supplier, accumulator, combiner, castingIdentity(), characteristics); in CollectorImpl()
179 public Supplier<A> supplier() { in supplier() method in CollectorImpl
180 return supplier; in supplier()
354 return new CollectorImpl<>(downstream.supplier(),
390 return new CollectorImpl<>(downstream.supplier(),
904 Supplier<A> downstreamSupplier = downstream.supplier();
[all …]
DDoublePipeline.java145 Supplier<Spliterator<P_IN>> supplier, in wrap() argument
147 return new StreamSpliterators.DoubleWrappingSpliterator<>(ph, supplier, isParallel); in wrap()
152 …blic final Spliterator.OfDouble lazySpliterator(Supplier<? extends Spliterator<Double>> supplier) { in lazySpliterator() argument
153 …n new StreamSpliterators.DelegatingSpliterator.OfDouble((Supplier<Spliterator.OfDouble>) supplier); in lazySpliterator()
470 public final <R> R collect(Supplier<R> supplier,
477 return evaluate(ReduceOps.makeDouble(supplier, accumulator, operator));
DLongPipeline.java146 Supplier<Spliterator<P_IN>> supplier, in wrap() argument
148 return new StreamSpliterators.LongWrappingSpliterator<>(ph, supplier, isParallel); in wrap()
153 … public final Spliterator.OfLong lazySpliterator(Supplier<? extends Spliterator<Long>> supplier) { in lazySpliterator() argument
154 …eturn new StreamSpliterators.DelegatingSpliterator.OfLong((Supplier<Spliterator.OfLong>) supplier); in lazySpliterator()
448 public final <R> R collect(Supplier<R> supplier,
455 return evaluate(ReduceOps.makeLong(supplier, accumulator, operator));
DIntPipeline.java148 Supplier<Spliterator<P_IN>> supplier, in wrap() argument
150 return new StreamSpliterators.IntWrappingSpliterator<>(ph, supplier, isParallel); in wrap()
155 …public final Spliterator.OfInt lazySpliterator(Supplier<? extends Spliterator<Integer>> supplier) { in lazySpliterator() argument
156 … return new StreamSpliterators.DelegatingSpliterator.OfInt((Supplier<Spliterator.OfInt>) supplier); in lazySpliterator()
466 public final <R> R collect(Supplier<R> supplier,
473 return evaluate(ReduceOps.makeInt(supplier, accumulator, operator));
DReferencePipeline.java115 Supplier<Spliterator<P_IN>> supplier, in wrap() argument
117 return new StreamSpliterators.WrappingSpliterator<>(ph, supplier, isParallel); in wrap()
121 … public final Spliterator<P_OUT> lazySpliterator(Supplier<? extends Spliterator<P_OUT>> supplier) { in lazySpliterator() argument
122 return new StreamSpliterators.DelegatingSpliterator<>(supplier); in lazySpliterator()
495 container = collector.supplier().get();
508 public final <R> R collect(Supplier<R> supplier,
511 return evaluate(ReduceOps.makeRef(supplier, accumulator, combiner));
DAbstractPipeline.java588 Supplier<Spliterator<P_IN>> supplier, in wrap() argument
596 …ublic abstract Spliterator<E_OUT> lazySpliterator(Supplier<? extends Spliterator<E_OUT>> supplier); in lazySpliterator() argument
DDoubleStream.java451 <R> R collect(Supplier<R> supplier, in collect() argument
DIntStream.java445 <R> R collect(Supplier<R> supplier, in collect() argument
DLongStream.java449 <R> R collect(Supplier<R> supplier, in collect() argument
DStream.java748 <R> R collect(Supplier<R> supplier, in collect() argument
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DSpliteratorTest.java48 public void testSpliterator(String name, Supplier<Spliterator<Integer>> supplier) { in testSpliterator() argument
49 SpliteratorTestHelper.testSpliterator(supplier); in testSpliterator()
53 public void testIntSpliterator(String name, Supplier<Spliterator.OfInt> supplier) { in testIntSpliterator() argument
54 SpliteratorTestHelper.testIntSpliterator(supplier); in testIntSpliterator()
58 public void testLongSpliterator(String name, Supplier<Spliterator.OfLong> supplier) { in testLongSpliterator() argument
59 SpliteratorTestHelper.testLongSpliterator(supplier); in testLongSpliterator()
63 public void testDoubleSpliterator(String name, Supplier<Spliterator.OfDouble> supplier) { in testDoubleSpliterator() argument
64 SpliteratorTestHelper.testDoubleSpliterator(supplier); in testDoubleSpliterator()
DStreamBuilderTest.java120 private void testStreamBuilder(int size, Function<Integer, Stream<Integer>> supplier) { in testStreamBuilder() argument
122 () -> supplier.apply(size)); in testStreamBuilder()
182 private void testIntStreamBuilder(int size, Function<Integer, IntStream> supplier) { in testIntStreamBuilder() argument
184 () -> supplier.apply(size)); in testIntStreamBuilder()
244 private void testLongStreamBuilder(int size, Function<Integer, LongStream> supplier) { in testLongStreamBuilder() argument
246 () -> supplier.apply(size)); in testLongStreamBuilder()
305 private void testDoubleStreamBuilder(int size, Function<Integer, DoubleStream> supplier) { in testDoubleStreamBuilder() argument
307 () -> supplier.apply(size)); in testDoubleStreamBuilder()
DGroupByOpTest.java66 Map<Boolean, List<Integer>> m = collector.supplier().get(); in testBypassCollect()
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DSpliteratorTestHelper.java59 public static void testSpliterator(Supplier<Spliterator<Integer>> supplier) { in testSpliterator() argument
60 testSpliterator(supplier, defaultContentAsserter()); in testSpliterator()
63 public static void testSpliterator(Supplier<Spliterator<Integer>> supplier, in testSpliterator() argument
65 testSpliterator(supplier, (Consumer<Integer> b) -> b, asserter); in testSpliterator()
68 public static void testIntSpliterator(Supplier<Spliterator.OfInt> supplier) { in testIntSpliterator() argument
69 testIntSpliterator(supplier, defaultContentAsserter()); in testIntSpliterator()
72 public static void testIntSpliterator(Supplier<Spliterator.OfInt> supplier, in testIntSpliterator() argument
92 testSpliterator(supplier, BoxingAdapter::new, asserter); in testIntSpliterator()
95 public static void testLongSpliterator(Supplier<Spliterator.OfLong> supplier) { in testLongSpliterator() argument
96 testLongSpliterator(supplier, defaultContentAsserter()); in testLongSpliterator()
[all …]
DTestData.java96 public static <T> OfRef<T> ofSupplier(String name, Supplier<Stream<T>> supplier) { in ofSupplier() argument
97 return new AbstractTestData.RefTestData<>(name, supplier, in ofSupplier()
126 public static OfInt ofIntSupplier(String name, Supplier<IntStream> supplier) { in ofIntSupplier() argument
127 return new AbstractTestData.IntTestData<>(name, supplier, in ofIntSupplier()
157 public static OfLong ofLongSupplier(String name, Supplier<LongStream> supplier) { in ofLongSupplier() argument
158 return new AbstractTestData.LongTestData<>(name, supplier, in ofLongSupplier()
188 public static OfDouble ofDoubleSupplier(String name, Supplier<DoubleStream> supplier) { in ofDoubleSupplier() argument
189 return new AbstractTestData.DoubleTestData<>(name, supplier, in ofDoubleSupplier()
DStreamTestDataProvider.java173 static <T> Object[] streamDataDescr(String description, Supplier<Stream<T>> supplier) { in streamDataDescr() argument
174 return new Object[] { description, TestData.Factory.ofSupplier(description, supplier)}; in streamDataDescr()
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DSpliteratorTestHelper.java59 public static void testSpliterator(Supplier<Spliterator<Integer>> supplier) { in testSpliterator() argument
60 testSpliterator(supplier, defaultContentAsserter()); in testSpliterator()
63 public static void testSpliterator(Supplier<Spliterator<Integer>> supplier, in testSpliterator() argument
65 testSpliterator(supplier, (Consumer<Integer> b) -> b, asserter); in testSpliterator()
68 public static void testIntSpliterator(Supplier<Spliterator.OfInt> supplier) { in testIntSpliterator() argument
69 testIntSpliterator(supplier, defaultContentAsserter()); in testIntSpliterator()
72 public static void testIntSpliterator(Supplier<Spliterator.OfInt> supplier, in testIntSpliterator() argument
92 testSpliterator(supplier, BoxingAdapter::new, asserter); in testIntSpliterator()
95 public static void testLongSpliterator(Supplier<Spliterator.OfLong> supplier) { in testLongSpliterator() argument
96 testLongSpliterator(supplier, defaultContentAsserter()); in testLongSpliterator()
[all …]
DTestData.java97 public static <T> OfRef<T> ofSupplier(String name, Supplier<Stream<T>> supplier) { in ofSupplier() argument
98 return new AbstractTestData.RefTestData<>(name, supplier, in ofSupplier()
127 public static OfInt ofIntSupplier(String name, Supplier<IntStream> supplier) { in ofIntSupplier() argument
128 return new AbstractTestData.IntTestData<>(name, supplier, in ofIntSupplier()
158 public static OfLong ofLongSupplier(String name, Supplier<LongStream> supplier) { in ofLongSupplier() argument
159 return new AbstractTestData.LongTestData<>(name, supplier, in ofLongSupplier()
189 public static OfDouble ofDoubleSupplier(String name, Supplier<DoubleStream> supplier) { in ofDoubleSupplier() argument
190 return new AbstractTestData.DoubleTestData<>(name, supplier, in ofDoubleSupplier()
DStreamTestDataProvider.java176 static <T> Object[] streamDataDescr(String description, Supplier<Stream<T>> supplier) { in streamDataDescr() argument
177 return new Object[] { description, TestData.Factory.ofSupplier(description, supplier)}; in streamDataDescr()
/libcore/luni/src/main/java/java/util/concurrent/
DCompletableFuture.java1810 public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier) { in supplyAsync() argument
1811 return asyncSupplyStage(ASYNC_POOL, supplier); in supplyAsync()
1825 public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier, in supplyAsync() argument
1827 return asyncSupplyStage(screenExecutor(executor), supplier); in supplyAsync()
2455 public CompletableFuture<T> completeAsync(Supplier<? extends T> supplier, in completeAsync() argument
2457 if (supplier == null || executor == null) in completeAsync()
2459 executor.execute(new AsyncSupply<T>(this, supplier)); in completeAsync()
2475 public CompletableFuture<T> completeAsync(Supplier<? extends T> supplier) { in completeAsync() argument
2476 return completeAsync(supplier, defaultExecutor()); in completeAsync()
2736 (Supplier<? extends T> supplier, Executor executor) { in completeAsync() argument
[all …]