Searched refs:Stream (Results 51 - 75 of 461) sorted by relevance

1234567891011>>

/openjdk10/langtools/test/tools/sjavac/
H A DNoState.java38 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 DAccessControlContextFactory.java32 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 DAccessControlContextFactory.java32 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 DT8152832.java38 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 DStreamParSeqTest.java28 import java.util.stream.Stream;
37 Stream<Integer> s = Arrays.asList(1, 2, 3, 4).stream().parallel();
H A DConcatTest.java40 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 DIterateTest.java37 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 DWhileOpStatefulTest.java41 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 DModuleInfoWriter.java31 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 DStreamOpFlagTestHelper.java45 public static boolean isStreamOrdered(Stream<?> s) {
/openjdk10/langtools/test/tools/javac/lambda/
H A DTargetType54.java36 void test(Stream<Integer> si) {
/openjdk10/jdk/src/java.base/share/classes/java/util/
H A DCollection.java29 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 DStreamEncoderOut.java36 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 DCompiledVersionTest.java30 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 DT8016177f.java56 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 DGenOpenModule.java41 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 DGenModuleInfo.java46 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 DStreamTest.java29 * @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 DMergeTest.java32 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 DBindServices.java34 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 DProcess.java33 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 DCheckOverrides.java28 import java.util.stream.Stream;
41 Stream.of(Properties.class.getDeclaredMethods())
50 Stream.of(superclass.getDeclaredMethods())
/openjdk10/jdk/test/tools/jimage/
H A DJImageListTest.java39 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 DMaskCommentsAndModifiers.java30 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 DStreamZipEntriesTest.java36 import java.util.stream.Stream;
78 Stream s = zf.stream();
90 Stream s = jf.stream();

Completed in 262 milliseconds

1234567891011>>