Home
last modified time | relevance | path

Searched refs:Stream (Results 1 – 25 of 173) sorted by relevance

1234567

/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DSequentialOpTest.java39 import java.util.stream.Stream;
56 …Supplier<Stream<Integer>>[] suppliers = new Supplier[] { () -> data.stream(), () -> data.parallelS… in testLazy()
57 UnaryOperator<Stream<Integer>>[] configs in testLazy()
59 … (UnaryOperator<Stream<Integer>>) s -> s.peek(e -> { counter.incrementAndGet(); }), in testLazy()
60 …(UnaryOperator<Stream<Integer>>) s -> s.map(id).peek(e -> { counter.incrementAndGet(); }).sequenti… in testLazy()
61 …(UnaryOperator<Stream<Integer>>) s -> s.map(id).peek(e -> { counter.incrementAndGet(); }).parallel… in testLazy()
62 (UnaryOperator<Stream<Integer>>) s -> s.sequential().map(id).peek(e -> { in testLazy()
65 …(UnaryOperator<Stream<Integer>>) s -> s.parallel().map(id).peek(e -> { counter.incrementAndGet(); … in testLazy()
70 Supplier<Stream<Integer>> supp = suppliers[i]; in testLazy()
73 UnaryOperator<Stream<Integer>> config = configs[j]; in testLazy()
[all …]
DWhileOpStatefulTest.java41 import java.util.stream.Stream;
242 private void testTakeWhileMulti(Consumer<Stream<Integer>> mRef) { in testTakeWhileMulti()
246 Map<String, Supplier<Stream<Integer>>> sources = new HashMap<>(); in testTakeWhileMulti()
247 sources.put("Stream.generate()", () -> Stream.generate(() -> 1)); in testTakeWhileMulti()
248 sources.put("Stream.iterate()", () -> Stream.iterate(1, x -> 1)); in testTakeWhileMulti()
249 sources.put("Stream.iterate().unordered()", () -> Stream.iterate(1, x -> 1)); in testTakeWhileMulti()
263 private void testDropWhileMulti(Consumer<Stream<Integer>> mRef) { in testDropWhileMulti()
264 Map<String, Supplier<Stream<Integer>>> sources = new HashMap<>(); in testDropWhileMulti()
283 private void testWhileMulti(Map<String, Supplier<Stream<Integer>>> sources, in testWhileMulti()
284 Consumer<Stream<Integer>> mRef) { in testWhileMulti()
[all …]
DStreamCloseTest.java28 import java.util.stream.Stream;
47 checkNPE(() -> Stream.of(1).onClose(null)); in testNullCloseHandler()
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()
72 try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(closer)) { in testOneCloseHandler()
78 …try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(closer).filter(e -> tr… in testOneCloseHandler()
89 try (Stream<Integer> ints = countTo(100).stream()) { in testTwoCloseHandlers()
96 try (Stream<Integer> ints = countTo(100).stream().onClose(close1).onClose(close2)) { in testTwoCloseHandlers()
102 …try (Stream<Integer> ints = countTo(100).stream().filter(e -> true).onClose(close1).onClose(close2… in testTwoCloseHandlers()
[all …]
DConcatTest.java42 import java.util.stream.Stream;
109 Stream<Integer> s1s = c1.stream(); in checkPrerequisites()
110 Stream<Integer> s2s = c2.stream(); in checkPrerequisites()
111 Stream<Integer> s1p = c1.parallelStream(); in checkPrerequisites()
112 Stream<Integer> s2p = c2.parallelStream(); in checkPrerequisites()
145 …private void assertRefConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean ord… in assertRefConcat()
146 Stream<Integer> result = Stream.concat(s1, s2); in assertRefConcat()
151 …private void assertIntConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean ord… in assertIntConcat()
159 …private void assertLongConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean or… in assertLongConcat()
167 …private void assertDoubleConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean … in assertDoubleConcat()
DIterateTest.java40 import java.util.stream.Stream;
54 Factory.ofSupplier("ref.empty", () -> Stream.iterate(1, x -> x < 0, x -> x * 2))}, in makeIterateStreamsTestData()
56 Factory.ofSupplier("ref.one", () -> Stream.iterate(1, x -> x < 2, x -> x * 2))}, in makeIterateStreamsTestData()
58 Factory.ofSupplier("ref.ten", () -> Stream.iterate(1, x -> x < 1000, x -> x * 2))}, in makeIterateStreamsTestData()
60 …Factory.ofSupplier("ref.nullCheck", () -> Stream.iterate(10, Objects::nonNull, x -> x > 0 ? x - 1 … in makeIterateStreamsTestData()
92 checkNPE(() -> Stream.iterate("", null, x -> x + "a")); in testNPE()
93 checkNPE(() -> Stream.iterate("", String::isEmpty, null)); in testNPE()
DConcatOpTest.java33 import java.util.stream.Stream;
51 s -> Stream.concat(s, data.stream()), in testOps()
58 assertSized(Stream.concat( in testSize()
62 assertUnsized(Stream.concat( in testSize()
66 assertUnsized(Stream.concat( in testSize()
68 Stream.iterate(0, i -> i + 1))); in testSize()
70 assertUnsized(Stream.concat( in testSize()
71 Stream.iterate(0, i -> i + 1), in testSize()
DWhileOpTest.java47 import java.util.stream.Stream;
301 Function<Stream<Integer>, Stream<Integer>> mRef,
305 Map<String, Function<Stream<Integer>, Stream<Integer>>> ms = new HashMap<>();
320 Map<String, Function<Stream<Integer>, Stream<Integer>>> ms) {
321 for (Map.Entry<String, Function<Stream<Integer>, Stream<Integer>>> e : ms.entrySet()) {
334 Stream<Integer> s = Stream.of(1, 2, 3).onClose(() -> isClosed.set(true));
335 try (Stream<Integer> ds = DefaultMethodStreams.delegateTo(s).takeWhile(e -> e < 3)) {
382 s -> Stream.<Integer[]>of(s.toArray(Integer[]::new)).
383 flatMap(Stream::of).
385 s -> Stream.of(s.mapToInt(e -> e).toArray()).
[all …]
DCountTest.java44 import java.util.stream.Stream;
59 terminal(Stream::count). in testOps()
64 terminal(s -> s.skip(1), Stream::count). in testOps()
70 terminal(s -> s.filter(e -> true), Stream::count). in testOps()
85 terminal(Stream::distinct, Stream::count). in testOps()
89 terminal(s -> s.unordered().distinct(), Stream::count). in testOps()
186 checkStreamDoesNotConsumeElements(() -> Stream.of(1, 2, 3, 4), 4); in testNoEvaluationForSizedStream()
187 checkStreamDoesNotConsumeElements(() -> Stream.of(1, 2, 3, 4).skip(1).limit(2).skip(1), 1); in testNoEvaluationForSizedStream()
196 … private void checkStreamDoesNotConsumeElements(Supplier<Stream<?>> supplier, long expectedCount) { in checkStreamDoesNotConsumeElements()
/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/
DStreamFlagsTest.java28 import java.util.stream.Stream;
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();
48 Stream<String> repeat = Stream.generate(() -> "");
50 Stream<?>[] streams = { arrayList, linkedList, hashSet, treeSet, linkedHashSet, repeat };
60 Stream<String> arrayList = new ArrayList<String>().stream(); in testBaseStreams()
61 Stream<String> linkedList = new LinkedList<String>().stream(); in testBaseStreams()
[all …]
DStreamReuseTest.java85 public void testTwoStreams(String name, TestData<Integer, Stream<Integer>> data) { in testTwoStreams()
87 … (Stream<Integer> s) -> s.map(i -> i), (Stream<Integer> s) -> s.map(i -> i), in testTwoStreams()
91 Stream::distinct, (Stream<Integer> s) -> s.map(i -> i), in testTwoStreams()
95 (Stream<Integer> s) -> s.map(i -> i), Stream::distinct, in testTwoStreams()
99 Stream::distinct, Stream::distinct, in testTwoStreams()
105 public void testTwoTerminals(String name, TestData<Integer, Stream<Integer>> data) { in testTwoTerminals()
107 Stream::findFirst, Stream::findFirst, in testTwoTerminals()
113 public void testTerminalStream(String name, TestData<Integer, Stream<Integer>> data) { in testTerminalStream()
115 Stream::findFirst, (Stream<Integer> s) -> s.map(i -> i), in testTerminalStream()
119 (Stream<Integer> s) -> s.map(i -> i), Stream::findFirst, in testTerminalStream()
[all …]
/libcore/ojluni/src/test/java/lang/StackWalker/
DWalkFunction.java36 import java.util.stream.Stream;
53 walker.walk(Stream::count); in testFunctions()
66 static Optional<StackFrame> reduce(Stream<StackFrame> stream) { in reduce()
89 Function<? super Stream<? extends StackFrame>, Void> f1 = WalkFunction::function; in testWildcards()
90 Function<? super Stream<? super StackFrame>, Void> f2 = WalkFunction::function; in testWildcards()
91 Function<? super Stream<StackFrame>, Void> f3 = WalkFunction::function; in testWildcards()
92 Function<Stream<? extends StackFrame>, Void> f4 = WalkFunction::function; in testWildcards()
93 Function<Stream<? super StackFrame>, Void> f5 = WalkFunction::function; in testWildcards()
94 Function<Stream<StackFrame>, Void> f6 = WalkFunction::function; in testWildcards()
103 private static Void function(Stream<?> s) { in function()
[all …]
DStackStreamState.java34 import java.util.stream.Stream;
45 private static Stream<StackFrame> staticStream;
46 private Stream<StackFrame> instanceStream;
74 Stream<StackFrame> stream = walker.walk(s -> { in testLocal()
79 void checkStreamState(Stream<StackFrame> stream) { in checkStreamState()
/libcore/ojluni/src/main/java/java/util/stream/
DStream.java164 public interface Stream<T> extends BaseStream<T, Stream<T>> { interface
179 Stream<T> filter(Predicate<? super T> predicate); in filter()
194 <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()
576 Stream<T> distinct();
592 Stream<T> sorted();
609 Stream<T> sorted(Comparator<? super T> comparator);
645 Stream<T> peek(Consumer<? super T> action);
672 Stream<T> limit(long maxSize);
[all …]
/libcore/luni/src/test/java/libcore/java/util/stream/
DMapMultiTest.java34 import java.util.stream.Stream;
60 assertThrows(NullPointerException.class, () -> Stream.of().mapMultiToInt(null)); in shouldThrowNPE_whenConsumerIsNull()
61 assertThrows(NullPointerException.class, () -> Stream.of().mapMultiToLong(null)); in shouldThrowNPE_whenConsumerIsNull()
62 assertThrows(NullPointerException.class, () -> Stream.of().mapMultiToDouble(null)); in shouldThrowNPE_whenConsumerIsNull()
67 int[] result = Stream.of(10, 20, 30).mapMultiToInt(intToId).toArray(); in testMapMultiToInt_toId()
74 long[] result = Stream.of(10L, 20L, 30L).mapMultiToLong(longToId).toArray(); in testMapMultiToLong_toId()
81 double[] result = Stream.of(10.0, 20.0, 30.0).mapMultiToDouble(doubleToId).toArray(); in testMapMultiToDouble_toId()
88 int[] result = Stream.of(10, 20, 30).mapMultiToInt(intDevNull).toArray(); in testMapMultiToInt_noopSink()
95 long[] result = Stream.of(10L, 20L, 30L).mapMultiToLong(longDevNull).toArray(); in testMapMultiToLong_noopSink()
102 double[] result = Stream.of(10.0, 20.0, 30.0).mapMultiToDouble(doubleDevNull).toArray(); in testMapMultiToDouble_noopSink()
[all …]
DStreamTest.java24 import java.util.stream.Stream;
52 String[] array = Stream.of(object).toArray(String[]::new); in streamOfSingleObject()
63 String[] destArray = Stream.of(sourceArray) in streamOfObjects()
72 assertEquals(0, Stream.ofNullable(null).count()); in ofNullable_ofNull_isEmpty()
77 assertArrayEquals(new Integer[] {10}, Stream.ofNullable(10).toArray()); in ofNullable_ofNonNull()
82 assertEquals(1, Stream.ofNullable(Stream.of(10, 20, 30)).count()); in ofNullable_ofNonNullStream()
DCollectorsTest.java38 import java.util.stream.Stream;
45 long count = Stream.of(null, null, null).collect(counting()); in counting_countsNulls()
52 assertEquals(0L, (long) Stream.empty().collect(counting())); in counting_emptyStream()
57 long count = Stream.of(null, 1, 2, "").collect(counting()); in counting_nonEmptyStream()
66 long actual = Stream.generate(() -> 1) in counting_largeStream()
92 assertArrayEquals(new int[] {30}, Stream.of(1, 2, 3, 4).collect(sqSumCollector)); in collectorOf()
100 List<Integer> actual = Stream.of(1, 2, 10).collect(plusOneCollector); in mapping_asArgumentToCollect()
110 Map<Boolean, List<Integer>> actual = Stream.of(1, 2, 3, 4) in mapping_asArgumentInGroupingBy()
/libcore/ojluni/src/main/java/java/util/random/
DRandomGenerator.java38 import java.util.stream.Stream;
862 Stream<RandomGenerator> rngs(); in rngs()
881 default Stream<RandomGenerator> rngs(long streamSize) { in rngs()
978 default Stream<SplittableGenerator> splits() { in splits()
997 Stream<SplittableGenerator> splits(long streamSize); in splits()
1016 Stream<SplittableGenerator> splits(SplittableGenerator source); in splits()
1034 Stream<SplittableGenerator> splits(long streamSize, SplittableGenerator source); in splits()
1046 default Stream<RandomGenerator> rngs() { in rngs()
1065 default Stream<RandomGenerator> rngs(long streamSize) { in rngs()
1168 default Stream<RandomGenerator> jumps() { in jumps()
[all …]
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DStreamTestScenario.java47 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_FOR_EACH_WITH_CLOSE()
48 Stream<U> s = m.apply(data.stream()); in STREAM_FOR_EACH_WITH_CLOSE()
60 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_COLLECT()
70 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_TO_ARRAY()
80 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_ITERATOR()
89 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_SPLITERATOR()
97 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_SPLITERATOR_WITH_MIXED_TRAVERSE_AND_SPLIT()
105 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_SPLITERATOR_FOREACH()
113 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in PAR_STREAM_SEQUENTIAL_FOR_EACH()
121 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in PAR_STREAM_FOR_EACH_ORDERED()
[all …]
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DStreamTestScenario.java50 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_FOR_EACH_WITH_CLOSE()
51 Stream<U> s = m.apply(data.stream()); in STREAM_FOR_EACH_WITH_CLOSE()
63 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_COLLECT()
73 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_TO_ARRAY()
83 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_ITERATOR()
92 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_SPLITERATOR()
100 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_SPLITERATOR_WITH_MIXED_TRAVERSE_AND_SPLIT()
108 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in STREAM_SPLITERATOR_FOREACH()
116 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in PAR_STREAM_SEQUENTIAL_FOR_EACH()
124 void _run(TestData<T, S_IN> data, Consumer<U> b, Function<S_IN, Stream<U>> m) { in PAR_STREAM_FOR_EACH_ORDERED()
[all …]
DDefaultMethodStreams.java93 Class<?> s = Stream.of(del.getInterfaces()) in verify()
98 Set<String> dms = Stream.of(s.getMethods()) in verify()
106 Set<String> ims = Stream.of(del.getMethods()) in verify()
127 public static <T> Stream<T> delegateTo(Stream<T> s) { in delegateTo()
176 static final class DefaultMethodRefStream<T> implements Stream<T> {
177 final Stream<T> s;
179 DefaultMethodRefStream(Stream<T> s) { in DefaultMethodRefStream()
187 public Stream<T> filter(Predicate<? super T> predicate) { in filter()
192 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()
[all …]
/libcore/ojluni/annotations/flagged_api/java/util/random/
DRandomGenerator.annotated.java110 public default java.util.stream.Stream<java.util.random.RandomGenerator.ArbitrarilyJumpableGenerato… in jumps()
112 public default java.util.stream.Stream<java.util.random.RandomGenerator.ArbitrarilyJumpableGenerato… in jumps()
131 public default java.util.stream.Stream<java.util.random.RandomGenerator> jumps() { throw new Runtim… in jumps()
133 public default java.util.stream.Stream<java.util.random.RandomGenerator> jumps(long streamSize) { t… in jumps()
135 public default java.util.stream.Stream<java.util.random.RandomGenerator> rngs() { throw new Runtime… in rngs()
137 public default java.util.stream.Stream<java.util.random.RandomGenerator> rngs(long streamSize) { th… in rngs()
154 public default java.util.stream.Stream<java.util.random.RandomGenerator.JumpableGenerator> leaps() … in leaps()
156 public default java.util.stream.Stream<java.util.random.RandomGenerator.JumpableGenerator> leaps(lo… in leaps()
171 public default java.util.stream.Stream<java.util.random.RandomGenerator.SplittableGenerator> splits… in splits()
173 public java.util.stream.Stream<java.util.random.RandomGenerator.SplittableGenerator> splits(long st… in splits()
[all …]
/libcore/ojluni/src/test/java/util/Random/
DRandomTestCoverage.java39 import java.util.stream.Stream;
112 Stream<RandomGenerator> rngs1 = rng.rngs(); in coverStreamable()
113 Stream<RandomGenerator> rngs2 = rng.rngs(5L); in coverStreamable()
119 Stream<SplittableGenerator> s3 = rng.splits(); in coverSplittable()
120 Stream<SplittableGenerator> s4 = rng.splits(5L); in coverSplittable()
121 Stream<SplittableGenerator> s5 = rng.splits(rng); in coverSplittable()
122 Stream<SplittableGenerator> s6 = rng.splits(5L, rng); in coverSplittable()
130 Stream<RandomGenerator> j3 = rng.jumps(); in coverJumpable()
131 Stream<RandomGenerator> j4 = rng.jumps(5L); in coverJumpable()
139 Stream<JumpableGenerator> l3 = rng.leaps(); in coverLeapable()
[all …]
/libcore/ojluni/src/test/java/util/StringJoiner/
DMergeTest.java34 import java.util.stream.Stream;
56 private static Stream<Fixes> fixesStream() { in fixesStream()
57 Stream.Builder<Fixes> builder = Stream.builder(); in fixesStream()
81 Stream.of("a", "b", "c").forEachOrdered(sj::add); in testSimple()
82 Stream.of("d", "e", "f").forEachOrdered(other::add); in testSimple()
93 Stream.of("a", "b", "c").forEachOrdered(sj::add); in testEmptyOther()
108 Stream.of("d", "e", "f").forEachOrdered(other::add); in testEmptyThis()
157 Stream.of("a", "b", "c").forEachOrdered(sj::add); in testDelimiter()
158 Stream.of("d", "e", "f").forEachOrdered(other::add); in testDelimiter()
/libcore/ojluni/src/main/java/java/security/
DPermissionCollection.java29 import java.util.stream.Stream;
91 public Stream<Permission> elementsAsStream() { in elementsAsStream()
102 return Stream.empty(); in elementsAsStream()
/libcore/ojluni/src/test/java/util/stream/examples/
DJavadocExamples.java30 import java.util.stream.Stream;
47 Stream<Number> numbers = Stream.of(1, 2, 3.0); in testNumberIntegerExample()
60 Stream<Object> expandedStream = nestedList.stream().mapMulti(C::expandIterable); in testExpandIterableExample()

1234567