/openjdk10/langtools/test/tools/sjavac/ |
H A D | NoState.java | 38 import java.util.stream.Stream; 62 try (Stream<Path> files = Files.list(dir)) {
|
/openjdk10/nashorn/src/jdk.dynalink/share/classes/jdk/dynalink/internal/ |
H A D | AccessControlContextFactory.java | 32 import java.util.stream.Stream; 75 return Stream.of(runtimePermissionNames).map(RuntimePermission::new).toArray(Permission[]::new);
|
/openjdk10/nashorn/src/jdk.scripting.nashorn/share/classes/jdk/nashorn/internal/runtime/ |
H A D | AccessControlContextFactory.java | 32 import java.util.stream.Stream; 75 return Stream.of(runtimePermissionNames).map(RuntimePermission::new).toArray(Permission[]::new);
|
/openjdk10/langtools/test/tools/javac/generics/inference/8152832/ |
H A D | T8152832.java | 38 interface MyStream<T> extends Stream<T> { 48 public static <T> void myStream(Supplier<Stream<T>> base, Consumer<MyStreamSupplier<T>> consumer) {
|
/openjdk10/jdk/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
H A D | StreamParSeqTest.java | 28 import java.util.stream.Stream; 37 Stream<Integer> s = Arrays.asList(1, 2, 3, 4).stream().parallel();
|
H A D | ConcatTest.java | 40 import java.util.stream.Stream; 101 Stream<Integer> s1s = c1.stream(); 102 Stream<Integer> s2s = c2.stream(); 103 Stream<Integer> s1p = c1.parallelStream(); 104 Stream<Integer> s2p = c2.parallelStream(); 136 private void assertRefConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean ordered) { 137 Stream<Integer> result = Stream.concat(s1, s2); 142 private void assertIntConcat(Stream<Intege [all...] |
H A D | IterateTest.java | 37 import java.util.stream.Stream; 53 Factory.ofSupplier("ref.empty", () -> Stream.iterate(1, x -> x < 0, x -> x * 2))}, 55 Factory.ofSupplier("ref.one", () -> Stream.iterate(1, x -> x < 2, x -> x * 2))}, 57 Factory.ofSupplier("ref.ten", () -> Stream.iterate(1, x -> x < 1000, x -> x * 2))}, 59 Factory.ofSupplier("ref.nullCheck", () -> Stream.iterate(10, Objects::nonNull, x -> x > 0 ? x - 1 : null))}, 91 checkNPE(() -> Stream.iterate("", null, x -> x + "a")); 92 checkNPE(() -> Stream.iterate("", String::isEmpty, null));
|
H A D | WhileOpStatefulTest.java | 41 import java.util.stream.Stream; 216 private void testTakeWhileMulti(Consumer<Stream<Integer>> mRef, 220 Map<String, Supplier<Stream<Integer>>> sources = new HashMap<>(); 221 sources.put("Stream.generate()", () -> Stream.generate(() -> 1)); 222 sources.put("Stream.iterate()", () -> Stream.iterate(1, x -> 1)); 223 sources.put("Stream.iterate().unordered()", () -> Stream.iterate(1, x -> 1)); 227 private void testDropWhileMulti(Consumer<Stream<Intege [all...] |
/openjdk10/jdk/src/java.base/share/classes/jdk/internal/module/ |
H A D | ModuleInfoWriter.java | 31 import java.util.stream.Stream; 58 Stream<String> exported = md.exports().stream() 60 Stream<String> open = md.opens().stream() 62 long exportedOrOpen = Stream.concat(exported, open).distinct().count();
|
/openjdk10/jdk/test/lib/testlibrary/bootlib/java.base/java/util/stream/ |
H A D | StreamOpFlagTestHelper.java | 45 public static boolean isStreamOrdered(Stream<?> s) {
|
/openjdk10/langtools/test/tools/javac/lambda/ |
H A D | TargetType54.java | 36 void test(Stream<Integer> si) {
|
/openjdk10/jdk/src/java.base/share/classes/java/util/ |
H A D | Collection.java | 29 import java.util.stream.Stream; 530 * Stream<E> s = StreamSupport.stream(() -> spliterator(), spliteratorCharacteristics) 566 * Returns a sequential {@code Stream} with this collection as its source. 574 * The default implementation creates a sequential {@code Stream} from the 577 * @return a sequential {@code Stream} over the elements in this collection 580 default Stream<E> stream() { 585 * Returns a possibly parallel {@code Stream} with this collection as its 594 * The default implementation creates a parallel {@code Stream} from the 597 * @return a possibly parallel {@code Stream} over the elements in this 601 default Stream< [all...] |
/openjdk10/jdk/test/sun/nio/cs/ |
H A D | StreamEncoderOut.java | 36 import java.util.stream.Stream; 66 flatMap(cs -> Stream.of(Input.values()).map(i -> new Object[]{cs, i})). 71 return Stream.generate(() -> s).limit(n).collect(joining());
|
/openjdk10/jdk/test/tools/jlink/plugins/SystemModuleDescriptors/ |
H A D | CompiledVersionTest.java | 30 import java.util.stream.Stream; 127 Stream<String> options = Stream.concat( 128 Stream.of(java.toString(), "-m", MAIN_MID, String.valueOf(modules.length)), 129 Stream.concat(Arrays.stream(modules), Arrays.stream(versions))
|
/openjdk10/langtools/test/tools/javac/lambda/8016177/ |
H A D | T8016177f.java | 56 interface OfRef<T> extends TestData<T, Stream<T>> { } 62 interface Stream<T> extends BaseStream<T, Stream<T>> { interface in class:T8016177f 63 <M> Stream<M> map(Function<T, M> s); 88 void test2(Function<Double, Integer> fdi, TestData.OfRef<Double> td, Stream<Integer> si) {
|
/openjdk10/langtools/test/tools/jdeps/modules/ |
H A D | GenOpenModule.java | 41 import java.util.stream.Stream; 70 Stream<String> files = MODULES.stream() 74 Stream<String> options = Stream.concat( 75 Stream.of("--generate-open-module", DEST_DIR.toString()), files);
|
H A D | GenModuleInfo.java | 46 import java.util.stream.Stream; 92 try (Stream<Path> resources = Files.find(metaInf, Integer.MAX_VALUE, 106 try (Stream<Path> stream = Files.find(root, Integer.MAX_VALUE, 108 Stream<Path> entries = stream.filter(f -> { 161 Stream<String> files = MODULES.stream() 164 JdepsRunner.run(Stream.concat(Stream.of("-cp"), files).toArray(String[]::new)); 171 Stream<String> files = MODULES.stream() 175 Stream<String> options = Stream [all...] |
/openjdk10/jdk/test/java/nio/file/Files/ |
H A D | StreamTest.java | 29 * @summary Unit test for java.nio.file.Files methods that return a Stream 54 import java.util.stream.Stream; 142 try (Stream<Path> s = Files.list(testFolder)) { 149 try (Stream<Path> s = Files.list(testFolder.resolve("empty"))) { 158 try (Stream<Path> s = Files.walk(testFolder)) { 167 try (Stream<Path> s = Files.walk(testFolder, 1)) { 180 try (Stream<Path> s = Files.walk(testFolder, FileVisitOption.FOLLOW_LINKS)) { 189 try (Stream<Path> s = Files.walk(start, FileVisitOption.FOLLOW_LINKS)) { 286 try (Stream<Path> s = Files.find(testFolder, Integer.MAX_VALUE, pred)) { 293 try (Stream<Pat [all...] |
/openjdk10/jdk/test/java/util/StringJoiner/ |
H A D | MergeTest.java | 32 import java.util.stream.Stream; 54 private static Stream<Fixes> fixesStream() { 55 Stream.Builder<Fixes> builder = Stream.builder(); 79 Stream.of("a", "b", "c").forEachOrdered(sj::add); 80 Stream.of("d", "e", "f").forEachOrdered(other::add); 91 Stream.of("a", "b", "c").forEachOrdered(sj::add); 106 Stream.of("d", "e", "f").forEachOrdered(other::add); 155 Stream.of("a", "b", "c").forEachOrdered(sj::add); 156 Stream [all...] |
/openjdk10/jdk/test/tools/jlink/bindservices/ |
H A D | BindServices.java | 34 import java.util.stream.Stream; 176 String[] cmd = Stream.concat( 177 Stream.of(java.toString(), "-m", "m1/p1.Main"), 178 Stream.of(modules)).toArray(String[]::new); 200 Stream.of(options).collect(Collectors.joining(" "))); 206 Stream.of(writer.toString().split("\\v"))
|
/openjdk10/jdk/src/java.base/share/classes/java/lang/ |
H A D | Process.java | 33 import java.util.stream.Stream; 513 * @return a sequential Stream of ProcessHandles for processes that are 521 public Stream<ProcessHandle> children() { 539 * @return a sequential Stream of ProcessHandles for processes that 547 public Stream<ProcessHandle> descendants() {
|
/openjdk10/jdk/test/java/util/Properties/ |
H A D | CheckOverrides.java | 28 import java.util.stream.Stream; 41 Stream.of(Properties.class.getDeclaredMethods()) 50 Stream.of(superclass.getDeclaredMethods())
|
/openjdk10/jdk/test/tools/jimage/ |
H A D | JImageListTest.java | 39 import java.util.stream.Stream; 55 List<String> modules = Stream.of(lines) 86 List<String> modules = Stream.of(lines) 93 Set<String> entries = Stream.of(lines) 111 Set<String> expected = Stream.of(listAll.output.split("[" + System.lineSeparator() + "]+")) 117 Set<String> actual = Stream.of(listJavaUtil.output.split("[" + System.lineSeparator() + "]+")) 126 Set<String> entries = Stream.of(listNotMatching.output.split("["+ System.lineSeparator() + "]+")) 147 Set<String> expected = Stream.of(listAll.output.split("[" + System.lineSeparator() + "]+")) 154 Set<String> actual = Stream.of(listJavaText.output.split("[" + System.lineSeparator() + "]+")) 165 Set<String> entries = Stream [all...] |
/openjdk10/langtools/src/jdk.jshell/share/classes/jdk/jshell/ |
H A D | MaskCommentsAndModifiers.java | 30 import java.util.stream.Stream; 40 Stream.of( "public", "protected", "private", "static", "final" ) 44 Stream.of( "abstract", "strictfp", "transient", "volatile", "synchronized", "native", "default" )
|
/openjdk10/jdk/test/java/util/zip/ZipFile/ |
H A D | StreamZipEntriesTest.java | 36 import java.util.stream.Stream; 78 Stream s = zf.stream(); 90 Stream s = jf.stream();
|