Home
last modified time | relevance | path

Searched refs:LongStream (Results 1 – 25 of 84) sorted by relevance

1234

/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DConcatOpTest.java35 import java.util.stream.LongStream;
53 s -> LongStream.concat(s, data.stream().mapToLong(Integer::longValue)), in testOps()
59 LongStream.range(0, Long.MAX_VALUE / 2).boxed(), in testSize()
60 LongStream.range(0, Long.MAX_VALUE / 2).boxed())); in testSize()
63 LongStream.range(0, Long.MAX_VALUE).boxed(), in testSize()
64 LongStream.range(0, Long.MAX_VALUE).boxed())); in testSize()
67 LongStream.range(0, Long.MAX_VALUE).boxed(), in testSize()
72 LongStream.range(0, Long.MAX_VALUE).boxed())); in testSize()
76 assertSized(LongStream.concat( in testLongSize()
77 LongStream.range(0, Long.MAX_VALUE / 2), in testLongSize()
[all …]
DLongPrimitiveOpsTests.java36 import java.util.stream.LongStream;
50 long sum = LongStream.range(1, 10).filter(i -> i % 2 == 0).sum(); in testSum()
55 long sum = LongStream.range(1, 10).filter(i -> i % 2 == 0).map(i -> i * 2).sum(); in testMap()
60 long sum = LongStream.range(1, 10).parallel().filter(i -> i % 2 == 0).sum(); in testParSum()
67 …long sum = LongStream.range(1, 10).filter(i -> i % 2 == 0).peek(i -> { teeSum[0] = teeSum[0] + i; … in testTee()
74 LongStream.range(1, 10).filter(i -> i % 2 == 0).forEach(i -> { sum[0] = sum[0] + i; }); in testForEach()
81 LongStream.range(1, 10).parallel().filter(i -> i % 2 == 0).forEach(ai::addAndGet); in testParForEach()
86 List<Long> l = LongStream.range(1, 10).parallel().boxed().collect(Collectors.toList()); in testBox()
97 assertTrue(LongStream.range(1, 10).boxed().spliterator() in testFlags()
99 assertFalse(LongStream.of(1, 10).boxed().spliterator() in testFlags()
[all …]
DCountLargeTest.java32 import java.util.stream.LongStream;
49 long count = LongStream.range(0, EXPECTED_LARGE_COUNT) in testRefLarge()
55 long count = LongStream.range(0, EXPECTED_LARGE_COUNT) in testRefLarge()
64 long count = LongStream.range(0, EXPECTED_LARGE_COUNT) in testIntLarge()
70 long count = LongStream.range(0, EXPECTED_LARGE_COUNT) in testIntLarge()
79 long count = LongStream.range(0, EXPECTED_LARGE_COUNT) in testLongLarge()
85 long count = LongStream.range(0, EXPECTED_LARGE_COUNT) in testLongLarge()
94 long count = LongStream.range(0, EXPECTED_LARGE_COUNT) in testDoubleLarge()
100 long count = LongStream.range(0, EXPECTED_LARGE_COUNT) in testDoubleLarge()
DDoublePrimitiveOpsTests.java32 import java.util.stream.LongStream;
54 assertTrue(LongStream.range(1, 10).asDoubleStream().boxed().spliterator() in testFlags()
62 double[] array = LongStream.range(1, 10).asDoubleStream().map(i -> i * 2).toArray(); in testToArray()
67 … double[] array = LongStream.range(1, 10).parallel().asDoubleStream().map(i -> i * 2).toArray(); in testToArray()
92 double[] range = LongStream.range(0, 10).asDoubleStream().toArray(); in testSortDistinct()
94 … assertEquals(LongStream.range(0, 10).asDoubleStream().sorted().distinct().toArray(), range); in testSortDistinct()
95 …assertEquals(LongStream.range(0, 10).asDoubleStream().parallel().sorted().distinct().toArray(), ra… in testSortDistinct()
133 … double[] actual = LongStream.range(1, 100).parallel().asDoubleStream().limit(9).toArray(); in testLimit()
DStreamBuilderTest.java39 import java.util.stream.LongStream;
211 () -> LongStream.of(1)); in testLongSingleton()
226 LongStream.Builder sb = LongStream.builder(); in testLongAfterBuilding()
227 LongStream.range(0, size).forEach(sb); in testLongAfterBuilding()
239 LongStream.Builder sb = LongStream.builder(); in testLongStreamBuilder()
240 LongStream.range(0, s).forEach(sb); in testLongStreamBuilder()
245 LongStream.Builder sb = LongStream.builder(); in testLongStreamBuilder()
246 LongStream.range(0, s).forEach(i -> { in testLongStreamBuilder()
247 LongStream.Builder _sb = sb.add(i); in testLongStreamBuilder()
254 private void testLongStreamBuilder(int size, Function<Integer, LongStream> supplier) { in testLongStreamBuilder()
[all …]
DMatchOpTest.java48 import java.util.stream.LongStream;
261 private final Map<Kind, Function<LongPredicate, Function<LongStream, Boolean>>> longKinds
262 = new HashMap<Kind, Function<LongPredicate, Function<LongStream, Boolean>>>() {{
268 …private void assertLongPredicates(Supplier<LongStream> source, Kind kind, LongPredicate[] predicat… in assertLongPredicates()
277 …assertLongPredicates(() -> LongStream.range(0, 0), Kind.ANY, LONG_PREDICATES, false, false, false,… in testLongStreamMatches()
278 …assertLongPredicates(() -> LongStream.range(0, 0), Kind.ALL, LONG_PREDICATES, true, true, true, tr… in testLongStreamMatches()
279 …assertLongPredicates(() -> LongStream.range(0, 0), Kind.NONE, LONG_PREDICATES, true, true, true, t… in testLongStreamMatches()
281 …assertLongPredicates(() -> LongStream.range(1, 2), Kind.ANY, LONG_PREDICATES, true, false, false, … in testLongStreamMatches()
282 …assertLongPredicates(() -> LongStream.range(1, 2), Kind.ALL, LONG_PREDICATES, true, false, false, … in testLongStreamMatches()
283 …assertLongPredicates(() -> LongStream.range(1, 2), Kind.NONE, LONG_PREDICATES, false, true, true, … in testLongStreamMatches()
[all …]
DRangeTest.java33 import java.util.stream.LongStream;
161 long[] inc = LongStream.range(start, end).toArray(); in testLongRange()
181 long[] inc = LongStream.rangeClosed(start, end).toArray(); in testLongRange()
192 long[] inc = LongStream.rangeClosed(Long.MAX_VALUE - 1, Long.MAX_VALUE).toArray(); in testLongRange()
197 inc = LongStream.rangeClosed(Long.MAX_VALUE, Long.MAX_VALUE).toArray(); in testLongRange()
202 () -> LongStream.rangeClosed(Long.MAX_VALUE - 8, Long.MAX_VALUE).spliterator()); in testLongRange()
207 return TestData.Factory.ofLongSupplier("long range", () -> LongStream.range(start, end));
211 …return TestData.Factory.ofLongSupplier("long rangeClosed", () -> LongStream.rangeClosed(start, end… in longRangeClosedData()
221 "long range", () -> LongStream.iterate(0, i -> i + 1).limit(10000))). in testLongInfiniteRangeLimit()
226 … long first = LongStream.iterate(0, i -> i + 1).filter(i -> i > 10000).findFirst().getAsLong(); in testLongInfiniteRangeFindFirst()
[all …]
DMinMaxTest.java40 import java.util.stream.LongStream;
81 assertEquals(LongStream.empty().min(), OptionalLong.empty()); in testLongMinMax()
82 assertEquals(LongStream.empty().max(), OptionalLong.empty()); in testLongMinMax()
83 assertEquals(1, LongStream.range(1, 1001).min().getAsLong()); in testLongMinMax()
84 assertEquals(1000, LongStream.range(1, 1001).max().getAsLong()); in testLongMinMax()
96 assertEquals(1.0, LongStream.range(1, 1001).asDoubleStream().min().getAsDouble()); in testDoubleMinMax()
97 assertEquals(1000.0, LongStream.range(1, 1001).asDoubleStream().max().getAsDouble()); in testDoubleMinMax()
DSortedOpTest.java45 import java.util.stream.LongStream;
61 Function<LongStream, Stream<Long>> f = s -> in testRefStreamTooLarge()
70 Function<LongStream, IntStream> f = s -> in testIntStreamTooLarge()
79 Function<LongStream, LongStream> f = s -> in testLongStreamTooLarge()
84 testStreamTooLarge(f, LongStream::findFirst); in testLongStreamTooLarge()
88 Function<LongStream, DoubleStream> f = s -> in testDoubleStreamTooLarge()
96 <T, S extends BaseStream<T, S>> void testStreamTooLarge(Function<LongStream, S> s, in testStreamTooLarge() argument
99 Supplier<LongStream> input = () -> LongStream.range(0, 1L + Integer.MAX_VALUE); in testStreamTooLarge()
102 List<Function<LongStream, LongStream>> transforms = Arrays.asList( in testStreamTooLarge()
109 for (Function<LongStream, LongStream> transform : transforms) { in testStreamTooLarge()
[all …]
DIterateTest.java40 import java.util.stream.LongStream;
71 … Factory.ofLongSupplier("long.empty", () -> LongStream.iterate(1L, x -> x < 0, x -> x + 1))}, in makeIterateStreamsTestData()
73 … Factory.ofLongSupplier("long.one", () -> LongStream.iterate(1L, x -> x < 2, x -> x + 1))}, in makeIterateStreamsTestData()
75 … Factory.ofLongSupplier("long.ten", () -> LongStream.iterate(1L, x -> x <= 10, x -> x + 1))}, in makeIterateStreamsTestData()
97 checkNPE(() -> LongStream.iterate(0, null, x -> x + 1)); in testNPE()
98 checkNPE(() -> LongStream.iterate(0, x -> x < 10, null)); in testNPE()
107 checkHasSplit(LongStream.iterate(0, x -> x < 10, x -> x + 1).boxed()); in testParallelize()
DCountTest.java43 import java.util.stream.LongStream;
129 terminal(LongStream::count). in testOps()
134 terminal(s -> s.skip(1), LongStream::count). in testOps()
139 terminal(s -> s.filter(e -> true), LongStream::count). in testOps()
145 terminal(LongStream::distinct, LongStream::count). in testOps()
149 terminal(s -> s.unordered().distinct(), LongStream::count). in testOps()
190 checkLongStreamDoesNotConsumeElements(() -> LongStream.of(1, 2, 3, 4), 4); in testNoEvaluationForSizedStream()
191 …checkLongStreamDoesNotConsumeElements(() -> LongStream.of(1, 2, 3, 4).skip(1).limit(2).skip(1), 1); in testNoEvaluationForSizedStream()
214 …private void checkLongStreamDoesNotConsumeElements(Supplier<LongStream> supplier, long expectedCou… in checkLongStreamDoesNotConsumeElements()
DStreamSpliteratorTest.java46 import java.util.stream.LongStream;
439 List<Consumer<LongStream>> terminalOps = Arrays.asList( in testLongSplitting()
445 List<UnaryOperator<LongStream>> intermediateOps = Arrays.asList( in testLongSplitting()
452 Consumer<LongStream> terminalOp = terminalOps.get(i); in testLongSplitting()
456 UnaryOperator<LongStream> intermediateOp = intermediateOps.get(j); in testLongSplitting()
461 … Spliterator.OfLong sp = intermediateOp.apply(LongStream.range(0, 1000)).spliterator(); in testLongSplitting()
463 LongStream s = StreamSupport.longStream(psp, true); in testLongSplitting()
483 for (Function<LongStream, LongStream> f : longStreamFunctions()) {
486 LongStream out = f.apply(in);
493 LongStream out = f.apply(in);
[all …]
DFlatMapOpTest.java41 import java.util.stream.LongStream;
60 checkNPE(() -> LongStream.of(1).flatMap(null)); in testNullMapper()
98 s.get().flatMapToLong(i -> LongStream.of(i, i).onClose(onClose::getAndIncrement)).count(); in testClose()
120 LongStream.of(1, 2).peek(e -> before.getAndIncrement()). in testLongClose()
121 flatMap(i -> LongStream.of(i, i).onClose(onClose::getAndIncrement)).count(); in testLongClose()
207 Collection<Long> result = exerciseOps(data, s -> s.flatMap(LongStream::of)); in testLongOps()
211 result = exerciseOps(data, s -> s.boxed().flatMapToLong(LongStream::of)); in testLongOps()
215 result = exerciseOps(data, s -> LongStream.empty()); in testLongOps()
221 exerciseOps(data, s -> s.flatMap(e -> LongStream.range(0, e))); in testLongOpsX()
222 exerciseOps(data, s -> s.flatMap(e -> LongStream.range(0, e).limit(10))); in testLongOpsX()
[all …]
DInfiniteStreamWithLimitOpTest.java47 import java.util.stream.LongStream;
98 (UnaryOperator<LongStream>) s -> s.limit(SKIP_LIMIT_SIZE)}); in longSliceFunctionsDataProvider()
100 (UnaryOperator<LongStream>) s -> s.skip(SKIP_LIMIT_SIZE).limit(SKIP_LIMIT_SIZE)}); in longSliceFunctionsDataProvider()
146 () -> LongStream.range(l, u).boxed());
166 () -> LongStream.range(l, u));
176 () -> LongStream.range(l, u).mapToDouble(i -> (double) i));
205 public void testLongSubsizedWithRange(String description, UnaryOperator<LongStream> fs) {
252 public void testLongUnorderedFinite(String description, UnaryOperator<LongStream> fs) {
306 … () -> StreamSupport.longStream(proxyNotSubsized(LongStream.range(l, u).spliterator()), false));
334 …ic void testLongUnorderedSizedNotSubsizedFinite(String description, UnaryOperator<LongStream> fs) {
[all …]
/libcore/ojluni/annotations/flagged_api/java/util/stream/
DLongStream.annotated.java29 public interface LongStream extends java.util.stream.BaseStream<java.lang.Long,java.util.stream.Lon… interface
31 public java.util.stream.LongStream filter(java.util.function.LongPredicate predicate); in filter()
33 public java.util.stream.LongStream map(java.util.function.LongUnaryOperator mapper); in map()
41 public java.util.stream.LongStream flatMap(java.util.function.LongFunction<? extends java.util.stre… in flatMap()
44 public default java.util.stream.LongStream mapMulti(java.util.stream.LongStream.LongMapMultiConsume… in mapMulti()
46 public java.util.stream.LongStream distinct(); in distinct()
48 public java.util.stream.LongStream sorted(); in sorted()
50 public java.util.stream.LongStream peek(java.util.function.LongConsumer action); in peek()
52 public java.util.stream.LongStream limit(long maxSize); in limit()
54 public java.util.stream.LongStream skip(long n); in skip()
[all …]
/libcore/ojluni/src/main/java/java/util/stream/
DLongStream.java73 public interface LongStream extends BaseStream<Long, LongStream> { interface
88 LongStream filter(LongPredicate predicate); in filter()
102 LongStream map(LongUnaryOperator mapper); in map()
165 LongStream flatMap(LongFunction<? extends LongStream> mapper); in flatMap()
195 default LongStream mapMulti(LongMapMultiConsumer mapper) { in mapMulti()
212 LongStream distinct(); in distinct()
223 LongStream sorted(); in sorted()
259 LongStream peek(LongConsumer action); in peek()
286 LongStream limit(long maxSize); in limit()
315 LongStream skip(long n); in skip()
[all …]
DLongPipeline.java57 extends AbstractPipeline<E_IN, Long, LongStream>
58 implements LongStream {
229 public final LongStream map(LongUnaryOperator mapper) {
289 public final LongStream flatMap(LongFunction<? extends LongStream> mapper) {
310 try (LongStream result = mapper.apply(t)) {
338 public final LongStream mapMulti(LongMapMultiConsumer mapper) {
363 public LongStream unordered() {
376 public final LongStream filter(LongPredicate predicate) {
400 public final LongStream peek(LongConsumer action) {
421 public final LongStream limit(long maxSize) {
[all …]
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DLongStreamTestScenario.java51 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in STREAM_FOR_EACH_WITH_CLOSE()
52 LongStream s = m.apply(data.stream()); in STREAM_FOR_EACH_WITH_CLOSE()
63 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in STREAM_TO_ARRAY()
72 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in STREAM_ITERATOR()
81 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in STREAM_SPLITERATOR()
90 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in STREAM_SPLITERATOR_WITH_MIXED_TRAVERSE_AND_SPLIT()
98 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in STREAM_SPLITERATOR_FOREACH()
105 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in PAR_STREAM_SEQUENTIAL_FOR_EACH()
113 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in PAR_STREAM_FOR_EACH_ORDERED()
122 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in PAR_STREAM_SPLITERATOR()
[all …]
DDefaultMethodStreams.java153 public static LongStream delegateTo(LongStream s) { in delegateTo()
202 public LongStream mapToLong(ToLongFunction<? super T> mapper) { in mapToLong()
222 public LongStream flatMapToLong(Function<? super T, ? extends LongStream> mapper) { in flatMapToLong()
413 public LongStream mapToLong(IntToLongFunction mapper) { in mapToLong()
538 public LongStream asLongStream() { in asLongStream()
593 static final class DefaultMethodLongStream implements LongStream {
594 final LongStream s;
596 public DefaultMethodLongStream(LongStream s) { in DefaultMethodLongStream()
609 public LongStream filter(LongPredicate predicate) { in filter()
614 public LongStream map(LongUnaryOperator mapper) { in map()
[all …]
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DLongStreamTestScenario.java48 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in STREAM_FOR_EACH_WITH_CLOSE()
49 LongStream s = m.apply(data.stream()); in STREAM_FOR_EACH_WITH_CLOSE()
60 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in STREAM_TO_ARRAY()
69 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in STREAM_ITERATOR()
78 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in STREAM_SPLITERATOR()
87 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in STREAM_SPLITERATOR_WITH_MIXED_TRAVERSE_AND_SPLIT()
95 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in STREAM_SPLITERATOR_FOREACH()
102 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in PAR_STREAM_SEQUENTIAL_FOR_EACH()
110 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in PAR_STREAM_FOR_EACH_ORDERED()
119 void _run(TestData<T, S_IN> data, LongConsumer b, Function<S_IN, LongStream> m) { in PAR_STREAM_SPLITERATOR()
[all …]
/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/
DStreamReuseTest.java267 … (LongStream s) -> s.mapToObj(i -> i), (LongStream s) -> s.mapToObj(i -> i), in testTwoStreams()
271 LongStream::distinct, (LongStream s) -> s.mapToObj(i -> i), in testTwoStreams()
275 (LongStream s) -> s.mapToObj(i -> i), LongStream::distinct, in testTwoStreams()
279 LongStream::distinct, LongStream::distinct, in testTwoStreams()
287 LongStream::sum, LongStream::sum, in testTwoTerminals()
295 LongStream::sum, (LongStream s) -> s.mapToObj(i -> i), in testTerminalStream()
299 (LongStream s) -> s.mapToObj(i -> i), LongStream::sum, in testTerminalStream()
303 LongStream::sum, LongStream::distinct, in testTerminalStream()
307 LongStream::distinct, LongStream::sum, in testTerminalStream()
315 LongStream::iterator, LongStream::iterator, in testTwoIterators()
[all …]
/libcore/luni/src/test/java/libcore/java/util/stream/
DLongStreamTest.java30 import java.util.stream.LongStream;
41 LongStream stream = LongStream.of(sourceArray); in ofArraysWithDifferentSizes()
54 LongStream.of((long[]) null); in ofNullArray_shouldThrowNPE()
/libcore/ojluni/src/main/java/java/util/
DOptionalLong.java30 import java.util.stream.LongStream;
204 public LongStream stream() { in stream()
206 return LongStream.of(value); in stream()
208 return LongStream.empty(); in stream()
/libcore/ojluni/annotations/flagged_api/java/util/concurrent/
DThreadLocalRandom.annotated.java89 public java.util.stream.LongStream longs(long streamSize) { throw new RuntimeException("Stub!"); } in longs()
91 public java.util.stream.LongStream longs() { throw new RuntimeException("Stub!"); } in longs()
93 public java.util.stream.LongStream longs(long streamSize, long randomNumberOrigin, long randomNumbe… in longs()
95 public java.util.stream.LongStream longs(long randomNumberOrigin, long randomNumberBound) { throw n… in longs()
/libcore/ojluni/annotations/flagged_api/java/util/
DRandom.annotated.java55 public java.util.stream.LongStream longs() { throw new RuntimeException("Stub!"); } in longs()
57 public java.util.stream.LongStream longs(long streamSize) { throw new RuntimeException("Stub!"); } in longs()
59 public java.util.stream.LongStream longs(long randomNumberOrigin, long randomNumberBound) { throw n… in longs()
61 public java.util.stream.LongStream longs(long streamSize, long randomNumberOrigin, long randomNumbe… in longs()

1234