Home
last modified time | relevance | path

Searched refs:stream (Results 1 – 25 of 490) sorted by relevance

12345678910>>...20

/libcore/ojluni/annotations/flagged_api/java/util/stream/
DIntStream.annotated.java26 package java.util.stream;
29 public interface IntStream extends java.util.stream.BaseStream<java.lang.Integer,java.util.stream.I…
31 public java.util.stream.IntStream filter(java.util.function.IntPredicate predicate); in filter()
33 public java.util.stream.IntStream map(java.util.function.IntUnaryOperator mapper); in map()
35 public <U> java.util.stream.Stream<U> mapToObj(java.util.function.IntFunction<? extends U> mapper); in mapToObj()
37 public java.util.stream.LongStream mapToLong(java.util.function.IntToLongFunction mapper); in mapToLong()
39 public java.util.stream.DoubleStream mapToDouble(java.util.function.IntToDoubleFunction mapper); in mapToDouble()
41 public java.util.stream.IntStream flatMap(java.util.function.IntFunction<? extends java.util.stream… in flatMap()
44 public default java.util.stream.IntStream mapMulti(java.util.stream.IntStream.IntMapMultiConsumer m… in mapMulti()
46 public java.util.stream.IntStream distinct(); in distinct()
[all …]
DLongStream.annotated.java26 package java.util.stream;
29 public interface LongStream extends java.util.stream.BaseStream<java.lang.Long,java.util.stream.Lon…
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()
35 public <U> java.util.stream.Stream<U> mapToObj(java.util.function.LongFunction<? extends U> mapper); in mapToObj()
37 public java.util.stream.IntStream mapToInt(java.util.function.LongToIntFunction mapper); in mapToInt()
39 public java.util.stream.DoubleStream mapToDouble(java.util.function.LongToDoubleFunction mapper); in mapToDouble()
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()
[all …]
DDoubleStream.annotated.java26 package java.util.stream;
29 public interface DoubleStream extends java.util.stream.BaseStream<java.lang.Double,java.util.stream…
31 public java.util.stream.DoubleStream filter(java.util.function.DoublePredicate predicate); in filter()
33 public java.util.stream.DoubleStream map(java.util.function.DoubleUnaryOperator mapper); in map()
35 public <U> java.util.stream.Stream<U> mapToObj(java.util.function.DoubleFunction<? extends U> mappe… in mapToObj()
37 public java.util.stream.IntStream mapToInt(java.util.function.DoubleToIntFunction mapper); in mapToInt()
39 public java.util.stream.LongStream mapToLong(java.util.function.DoubleToLongFunction mapper); in mapToLong()
41 public java.util.stream.DoubleStream flatMap(java.util.function.DoubleFunction<? extends java.util.… in flatMap()
44 public default java.util.stream.DoubleStream mapMulti(java.util.stream.DoubleStream.DoubleMapMultiC… in mapMulti()
46 public java.util.stream.DoubleStream distinct(); in distinct()
[all …]
DCollectors.annotated.java26 package java.util.stream;
33 public static <T, C extends java.util.Collection<T>> java.util.stream.Collector<T,?,C> toCollection… in toCollection()
35 public static <T> java.util.stream.Collector<T,?,java.util.List<T>> toList() { throw new RuntimeExc… in toList()
37 public static <T> java.util.stream.Collector<T,?,java.util.List<T>> toUnmodifiableList() { throw ne… in toUnmodifiableList()
39 public static <T> java.util.stream.Collector<T,?,java.util.Set<T>> toSet() { throw new RuntimeExcep… in toSet()
41 public static <T> java.util.stream.Collector<T,?,java.util.Set<T>> toUnmodifiableSet() { throw new … in toUnmodifiableSet()
43 public static java.util.stream.Collector<java.lang.CharSequence,?,java.lang.String> joining() { thr… in joining()
45 public static java.util.stream.Collector<java.lang.CharSequence,?,java.lang.String> joining(java.la… in joining()
47 public static java.util.stream.Collector<java.lang.CharSequence,?,java.lang.String> joining(java.la… in joining()
49 …<T, U, A, R> java.util.stream.Collector<T,?,R> mapping(java.util.function.Function<? super T,? ext… in mapping()
[all …]
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DConcatTest.java24 package org.openjdk.tests.java.util.stream;
39 import java.util.stream.DoubleStream;
40 import java.util.stream.IntStream;
41 import java.util.stream.LongStream;
42 import java.util.stream.Stream;
44 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.*;
109 Stream<Integer> s1s = c1.stream(); in checkPrerequisites()
110 Stream<Integer> s2s = c2.stream(); in checkPrerequisites()
156 expected.stream().mapToInt(Integer::intValue).spliterator()); in assertIntConcat()
164 expected.stream().mapToLong(Integer::longValue).spliterator()); in assertLongConcat()
[all …]
DPrimitiveSumTest.java23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.DoubleStreamTestDataProvider;
26 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
27 import org.openjdk.testlib.java.util.stream.LambdaTestHelpers;
28 import org.openjdk.testlib.java.util.stream.LongStreamTestDataProvider;
29 import org.openjdk.testlib.java.util.stream.OpTestCase;
30 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
31 import org.openjdk.testlib.java.util.stream.TestData;
33 import java.util.stream.BaseStream;
34 import java.util.stream.Stream;
[all …]
DStreamLinkTest.java23 package org.openjdk.tests.java.util.stream;
27 import org.openjdk.testlib.java.util.stream.DoubleStreamTestDataProvider;
28 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
29 import org.openjdk.testlib.java.util.stream.LambdaTestHelpers;
30 import org.openjdk.testlib.java.util.stream.LongStreamTestDataProvider;
31 import org.openjdk.testlib.java.util.stream.OpTestCase;
32 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
33 import org.openjdk.testlib.java.util.stream.TestData;
35 import java.util.stream.BaseStream;
36 import java.util.stream.Collectors;
[all …]
DMinMaxTest.java23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.DoubleStreamTestDataProvider;
26 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
27 import org.openjdk.testlib.java.util.stream.LambdaTestHelpers;
28 import org.openjdk.testlib.java.util.stream.LongStreamTestDataProvider;
29 import org.openjdk.testlib.java.util.stream.OpTestCase;
30 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
31 import org.openjdk.testlib.java.util.stream.TestData;
37 import java.util.stream.BaseStream;
38 import java.util.stream.Stream;
[all …]
DFindFirstOpTest.java23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.*;
28 import java.util.stream.BaseStream;
29 import java.util.stream.Stream;
30 import java.util.stream.IntStream;
31 import java.util.stream.LongStream;
32 import java.util.stream.DoubleStream;
38 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.*;
48 assertFalse(Collections.emptySet().stream().findFirst().isPresent(), "no result"); in testFindFirst()
49 assertFalse(countTo(10).stream().filter(x -> x > 10).findFirst().isPresent(), "no result"); in testFindFirst()
[all …]
DStreamCloseTest.java23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.OpTestCase;
28 import java.util.stream.Stream;
32 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.countTo;
35 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.countTo;
36 import static org.openjdk.testlib.java.util.stream.ThrowableHelper.checkNPE;
37 import static org.openjdk.testlib.java.util.stream.ThrowableHelper.checkISE;
50 try (Stream<Integer> ints = countTo(100).stream()) { in testEmptyCloseHandler()
59 try (Stream<Integer> ints = countTo(100).stream()) { in testOneCloseHandler()
66 try (Stream<Integer> ints = countTo(100).stream().onClose(closer)) { in testOneCloseHandler()
[all …]
DDistinctOpTest.java23 package org.openjdk.tests.java.util.stream;
28 import org.openjdk.testlib.java.util.stream.CollectorOps;
29 import org.openjdk.testlib.java.util.stream.OpTestCase;
30 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
31 import org.openjdk.testlib.java.util.stream.TestData;
40 import java.util.stream.Collectors;
41 import java.util.stream.DoubleStream;
42 import java.util.stream.IntStream;
43 import java.util.stream.LongStream;
44 import java.util.stream.Stream;
[all …]
DGroupByOpTest.java23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.LambdaTestHelpers;
26 import org.openjdk.testlib.java.util.stream.OpTestCase;
27 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
28 import org.openjdk.testlib.java.util.stream.TestData;
39 import java.util.stream.Collector;
40 import java.util.stream.Collectors;
41 import java.util.stream.Stream;
45 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.countTo;
46 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.mDoubler;
[all …]
DExplodeOpTest.java23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.DoubleStreamTestDataProvider;
26 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
27 import org.openjdk.testlib.java.util.stream.LambdaTestHelpers;
28 import org.openjdk.testlib.java.util.stream.LongStreamTestDataProvider;
29 import org.openjdk.testlib.java.util.stream.OpTestCase;
30 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
31 import org.openjdk.testlib.java.util.stream.TestData;
39 import java.util.stream.BaseStream;
40 import java.util.stream.Stream;
[all …]
DTeeOpTest.java23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.DoubleStreamTestDataProvider;
26 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
27 import org.openjdk.testlib.java.util.stream.LambdaTestHelpers;
28 import org.openjdk.testlib.java.util.stream.LongStreamTestDataProvider;
29 import org.openjdk.testlib.java.util.stream.OpTestCase;
30 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
31 import org.openjdk.testlib.java.util.stream.TestData;
44 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.*;
55 assertCountSum(countTo(0).stream().peek(copy::add), 0, 0); in testTee()
[all …]
DFindAnyOpTest.java23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.DoubleStreamTestDataProvider;
26 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
27 import org.openjdk.testlib.java.util.stream.LambdaTestHelpers;
28 import org.openjdk.testlib.java.util.stream.LongStreamTestDataProvider;
29 import org.openjdk.testlib.java.util.stream.OpTestCase;
30 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
31 import org.openjdk.testlib.java.util.stream.TestData;
36 import java.util.stream.Stream;
37 import java.util.stream.IntStream;
[all …]
DReduceByOpTest.java23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.LambdaTestHelpers;
26 import org.openjdk.testlib.java.util.stream.OpTestCase;
27 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
28 import org.openjdk.testlib.java.util.stream.TestData;
31 import java.util.stream.Stream;
37 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.*;
38 import static java.util.stream.Collectors.groupingBy;
39 import static java.util.stream.Collectors.reducing;
51 …Map<Boolean,List<Integer>> gbResult = data.stream().collect(groupingBy(LambdaTestHelpers.forPredic… in testOps()
[all …]
DSummaryStatisticsTest.java23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.OpTestCase;
32 import java.util.stream.Collectors;
36 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.countTo;
47 instances.add(countTo(1000).stream().collect(Collectors.summarizingInt(i -> i))); in testIntStatistics()
48 instances.add(countTo(1000).stream().mapToInt(i -> i).summaryStatistics()); in testIntStatistics()
54 assertEquals(stats.getSum(), countTo(1000).stream().mapToInt(i -> i).sum()); in testIntStatistics()
62 instances.add(countTo(1000).stream().collect(Collectors.summarizingLong(i -> i))); in testLongStatistics()
63 instances.add(countTo(1000).stream().mapToLong(i -> i).summaryStatistics()); in testLongStatistics()
69 assertEquals(stats.getSum(), (long) countTo(1000).stream().mapToInt(i -> i).sum()); in testLongStatistics()
[all …]
DReduceTest.java23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.OpTestCase;
26 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
27 import org.openjdk.testlib.java.util.stream.TestData;
29 import java.util.stream.Stream;
35 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.*;
47 assertEquals(55, (int) list.stream().reduce(rPlus).get()); in testReduce()
48 assertEquals(55, (int) list.stream().reduce(0, rPlus)); in testReduce()
49 assertEquals(10, (int) list.stream().reduce(rMax).get()); in testReduce()
50 assertEquals(1, (int) list.stream().reduce(rMin).get()); in testReduce()
[all …]
DIntUniqOpTest.java23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
26 import org.openjdk.testlib.java.util.stream.LambdaTestHelpers;
27 import org.openjdk.testlib.java.util.stream.OpTestCase;
28 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
29 import org.openjdk.testlib.java.util.stream.TestData;
32 import java.util.stream.Stream;
33 import java.util.stream.IntStream;
37 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.assertCountSum;
38 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.assertUnique;
[all …]
/libcore/ojluni/src/test/java/util/Arrays/
DStreamAndSpliterator.java45 assertThrowsNPE(() -> Arrays.stream((int[]) null, 0, 0)); in testStreamNPEs()
46 assertThrowsNPE(() -> Arrays.stream((long[]) null, 0, 0)); in testStreamNPEs()
47 assertThrowsNPE(() -> Arrays.stream((double[]) null, 0, 0)); in testStreamNPEs()
48 assertThrowsNPE(() -> Arrays.stream((String[]) null, 0, 0)); in testStreamNPEs()
54 assertThrowsAIOOB(() -> Arrays.stream(new int[]{}, 1, 0)); in testStreamAIOBEs()
55 assertThrowsAIOOB(() -> Arrays.stream(new long[]{}, 1, 0)); in testStreamAIOBEs()
56 assertThrowsAIOOB(() -> Arrays.stream(new double[]{}, 1, 0)); in testStreamAIOBEs()
57 assertThrowsAIOOB(() -> Arrays.stream(new String[]{}, 1, 0)); in testStreamAIOBEs()
60 assertThrowsAIOOB(() -> Arrays.stream(new int[]{}, -1, 0)); in testStreamAIOBEs()
61 assertThrowsAIOOB(() -> Arrays.stream(new long[]{}, -1, 0)); in testStreamAIOBEs()
[all …]
/libcore/luni/src/main/native/
DZipUtilities.cpp25 NativeZipStream* stream) { in throwExceptionForZlibError() argument
28 } else if (stream != NULL && stream->stream.msg != NULL) { in throwExceptionForZlibError()
29 jniThrowException(env, exceptionClassName, stream->stream.msg); in throwExceptionForZlibError()
37 stream.opaque = Z_NULL; in NativeZipStream()
38 stream.zalloc = Z_NULL; in NativeZipStream()
39 stream.zfree = Z_NULL; in NativeZipStream()
56 err = inflateSetDictionary(&stream, dictionary, len); in setDictionary()
58 err = deflateSetDictionary(&stream, dictionary, len); in setDictionary()
78 stream.next_in = reinterpret_cast<Bytef*>(&input[0]); in setInput()
79 stream.avail_in = len; in setInput()
/libcore/ojluni/annotations/flagged_api/java/util/
DSplittableRandom.annotated.java47 public java.util.stream.Stream<java.util.random.RandomGenerator.SplittableGenerator> splits() { thr… in splits()
50 public java.util.stream.Stream<java.util.random.RandomGenerator.SplittableGenerator> splits(long st… in splits()
53 public java.util.stream.Stream<java.util.random.RandomGenerator.SplittableGenerator> splits(java.ut… in splits()
56 public java.util.stream.Stream<java.util.random.RandomGenerator.SplittableGenerator> splits(long st… in splits()
58 public java.util.stream.IntStream ints(long streamSize) { throw new RuntimeException("Stub!"); } in ints()
60 public java.util.stream.IntStream ints() { throw new RuntimeException("Stub!"); } in ints()
62 public java.util.stream.IntStream ints(long streamSize, int randomNumberOrigin, int randomNumberBou… in ints()
64 public java.util.stream.IntStream ints(int randomNumberOrigin, int randomNumberBound) { throw new R… in ints()
66 public java.util.stream.LongStream longs(long streamSize) { throw new RuntimeException("Stub!"); } in longs()
68 public java.util.stream.LongStream longs() { throw new RuntimeException("Stub!"); } in longs()
[all …]
/libcore/ojluni/annotations/flagged_api/java/util/random/
DRandomGenerator.annotated.java39 public default java.util.stream.DoubleStream doubles() { throw new RuntimeException("Stub!"); } in doubles()
41 public default java.util.stream.DoubleStream doubles(double randomNumberOrigin, double randomNumber… in doubles()
43 public default java.util.stream.DoubleStream doubles(long streamSize) { throw new RuntimeException(… in doubles()
45 public default java.util.stream.DoubleStream doubles(long streamSize, double randomNumberOrigin, do… in doubles()
47 public default java.util.stream.IntStream ints() { throw new RuntimeException("Stub!"); } in ints()
49 public default java.util.stream.IntStream ints(int randomNumberOrigin, int randomNumberBound) { thr… in ints()
51 public default java.util.stream.IntStream ints(long streamSize) { throw new RuntimeException("Stub!… in ints()
53 public default java.util.stream.IntStream ints(long streamSize, int randomNumberOrigin, int randomN… in ints()
55 public default java.util.stream.LongStream longs() { throw new RuntimeException("Stub!"); } in longs()
57 public default java.util.stream.LongStream longs(long randomNumberOrigin, long randomNumberBound) {… in longs()
[all …]
/libcore/ojluni/annotations/flagged_api/java/util/concurrent/
DThreadLocalRandom.annotated.java81 public java.util.stream.IntStream ints(long streamSize) { throw new RuntimeException("Stub!"); } in ints()
83 public java.util.stream.IntStream ints() { throw new RuntimeException("Stub!"); } in ints()
85 public java.util.stream.IntStream ints(long streamSize, int randomNumberOrigin, int randomNumberBou… in ints()
87 public java.util.stream.IntStream ints(int randomNumberOrigin, int randomNumberBound) { throw new R… in ints()
89 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()
97 public java.util.stream.DoubleStream doubles(long streamSize) { throw new RuntimeException("Stub!")… in doubles()
99 public java.util.stream.DoubleStream doubles() { throw new RuntimeException("Stub!"); } in doubles()
[all …]
/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/
DStreamFlagsTest.java23 package java.util.stream;
28 import java.util.stream.Stream;
29 import java.util.stream.StreamOpFlag;
30 import java.util.stream.Streams;
32 import static java.util.stream.StreamOpFlag.*;
43 Stream<String> arrayList = new ArrayList<String>().stream();
44 Stream<String> linkedList = new LinkedList<String>().stream();
45 Stream<String> hashSet = new HashSet<String>().stream();
46 Stream<String> treeSet = new TreeSet<String>().stream();
47 Stream<String> linkedHashSet = new LinkedHashSet<String>().stream();
[all …]

12345678910>>...20