Searched defs:stream (Results 51 - 75 of 179) sorted by relevance

12345678

/libcore/ojluni/src/main/java/java/util/stream/
H A DAbstractShortCircuitTask.java25 package java.util.stream;
32 * stream ops, which can produce a result without processing all elements of the
33 * stream.
63 * @param helper the {@code PipelineHelper} describing the stream pipeline
H A DAbstractSpinedBuffer.java25 package java.util.stream;
H A DPipelineHelper.java25 package java.util.stream;
32 * stream pipelines</a>, capturing all of the information about a stream
33 * pipeline (output shape, intermediate operations, stream flags, parallelism,
37 * A {@code PipelineHelper} describes the initial segment of a stream pipeline,
47 * head shape, stream flags, and size, and use the helper methods
59 * Gets the stream shape for the source of the pipeline segment.
61 * @return the stream shape for the source of the pipeline segment.
66 * Gets the combined stream and operation flags for the output of the described
67 * pipeline. This will incorporate stream flag
[all...]
H A DSink.java25 package java.util.stream;
35 * a stream pipeline, with additional methods to manage size information,
54 * A stream pipeline consists of a source, zero or more intermediate stages
60 * = strings.stream()
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
H A DStatefulTestOp.java23 package java.util.stream;
H A DTestFlagExpectedOp.java23 package java.util.stream;
H A DCollectorOps.java23 package java.util.stream;
30 /** Test helper class for java.util.stream test framework */
/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/
H A 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...]
H A DStreamReuseTest.java23 package java.util.stream;
45 S stream = data.stream();
46 T fr = first.apply(stream);
48 U sr = second.apply(stream);
63 stream = data.parallelStream();
64 fr = first.apply(stream);
66 U sr = second.apply(stream);
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
H A DConcatOpTest.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;
32 import java.util.stream.BaseStream;
33 import java.util.stream.Stream;
34 import java.util.stream.IntStream;
35 import java.util.stream.LongStream;
36 import java.util.stream.DoubleStream;
38 import static org.openjdk.testlib.java.util.stream
[all...]
H A 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");
49 assertFalse(countTo(10).stream()
[all...]
H A DForEachOpTest.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;
42 import java.util.stream.BaseStream;
43 import java.util.stream
[all...]
H A DIntPrimitiveOpsTests.java23 package org.openjdk.tests.java.util.stream;
33 import java.util.stream.Collectors;
34 import java.util.stream.IntStream;
79 int sum = l.stream().reduce(0, (a, b) -> a + b);
84 long sum = Arrays.asList(1, 2, 3, 4, 5).stream().mapToInt(i -> (int) i).sum();
108 int[] array = Arrays.stream(content).sorted().toArray();
113 int[] array = Arrays.stream(content).parallel().sorted().toArray();
126 int[] array = Arrays.stream(content).sorted().sorted().toArray();
131 int[] array = Arrays.stream(content).parallel().sorted().sorted().toArray();
H A DLongPrimitiveOpsTests.java23 package org.openjdk.tests.java.util.stream;
33 import java.util.stream.Collectors;
34 import java.util.stream.LongStream;
79 long sum = l.stream().reduce(0L, (a, b) -> a + b);
84 long sum = Arrays.asList(1L, 2L, 3L, 4L, 5L).stream().mapToLong(i -> (long) i).sum();
108 long[] array = Arrays.stream(content).sorted().toArray();
113 long[] array = Arrays.stream(content).parallel().sorted().toArray();
126 long[] array = Arrays.stream(content).sorted().sorted().toArray();
131 long[] array = Arrays.stream(content).parallel().sorted().sorted().toArray();
H A 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
[all...]
H A DStreamLinkTest.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
[all...]
H A 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;
37 import java.util.stream.BaseStream;
38 import java.util.stream
[all...]
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
H A DStatelessTestOp.java23 package org.openjdk.testlib.java.util.stream;
25 import java.util.stream.AbstractPipeline;
26 import java.util.stream.DoublePipeline;
27 import java.util.stream.IntPipeline;
28 import java.util.stream.LongPipeline;
29 import java.util.stream.ReferencePipeline;
30 import java.util.stream.StreamShape;
31 import java.util.stream.Sink;
H A DTestFlagExpectedOp.java23 package org.openjdk.testlib.java.util.stream;
28 import java.util.stream.*;
/libcore/support/src/test/java/org/apache/harmony/security/tests/support/
H A DCertificateStub.java55 public void decode(InputStream stream) throws KeyException, argument
65 public void encode(OutputStream stream) throws KeyException, argument
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/
H A DOutputStreamTesterTest.java98 private ByteArrayOutputStream stream; field in class:OutputStreamTesterTest.ByteArrayOutputStreamSinkTester
105 stream = new ByteArrayOutputStream(size);
106 return stream;
110 return stream.toByteArray();
/libcore/ojluni/src/main/java/java/security/cert/
H A DCertPathValidatorException.java231 private void readObject(ObjectInputStream stream) argument
233 stream.defaultReadObject();
/libcore/ojluni/src/main/java/java/util/
H A DCollection.java29 import java.util.stream.Stream;
30 import java.util.stream.StreamSupport;
507 * preserve expected laziness behavior for the {@link #stream()} and
513 * and should override the {@link #stream()} and {@link #parallelStream()}
517 * Stream<E> s = StreamSupport.stream(() -> spliterator(), spliteratorCharacteristics)
520 * {@link #stream()} and {@link #parallelStream()} methods will reflect the
521 * contents of the collection as of initiation of the terminal stream
567 default Stream<E> stream() { method in interface:Collection
568 return StreamSupport.stream(spliterator(), false);
573 * source. It is allowable for this method to return a sequential stream
[all...]
/libcore/ojluni/src/main/java/sun/nio/ch/
H A DFileDescriptorHolderSocketImpl.java57 protected void create(boolean stream) throws IOException { argument
/libcore/ojluni/src/main/java/sun/security/pkcs/
H A DPKCS8Key.java259 * PKCS#8 sequence on the DER output stream.
319 * Initialize an PKCS8Key object from an input stream. The data
320 * on that input stream must be encoded using DER, obeying the
329 * @param in an input stream with a DER-encoded PKCS#8
381 private void readObject (ObjectInputStream stream) argument
385 decode(stream);

Completed in 736 milliseconds

12345678