Searched defs:stream (Results 1 - 25 of 185) sorted by relevance

12345678

/libcore/ojluni/src/main/java/java/util/stream/
H A DTerminalSink.java25 package java.util.stream;
H A Dpackage-info.java31 * int sum = widgets.stream()
38 * as a source for a stream, and then perform a filter-map-reduce on the stream
43 * <p>The key abstraction introduced in this package is <em>stream</em>. The
44 * classes {@link java.util.stream.Stream}, {@link java.util.stream.IntStream},
45 * {@link java.util.stream.LongStream}, and {@link java.util.stream.DoubleStream}
50 * <li>No storage. A stream is not a data structure that stores elements;
54 * <li>Functional in nature. An operation on a stream produce
[all...]
H A DDistinctOps.java25 package java.util.stream;
47 * Appends a "distinct" operation to the provided stream, and returns the
48 * new stream.
51 * @param upstream a reference stream with element type T
52 * @return the new stream
59 // If the stream is SORTED then it should also be ORDERED so the following will also
H A DStreamSupport.java25 package java.util.stream;
34 * <p>This class is mostly for library writers presenting stream views
35 * of data structures; most static stream methods intended for end users are in
50 * size after the terminal operation of the stream pipeline commences.
55 * {@link #stream(java.util.function.Supplier, int, boolean)} should be used
60 * @param <T> the type of stream elements
61 * @param spliterator a {@code Spliterator} describing the stream elements
62 * @param parallel if {@code true} then the returned stream is a parallel
63 * stream; if {@code false} the returned stream i
67 public static <T> Stream<T> stream(Spliterator<T> spliterator, boolean parallel) { method in class:StreamSupport
107 public static <T> Stream<T> stream(Supplier<? extends Spliterator<T>> supplier, method in class:StreamSupport
[all...]
H A DStreamShape.java25 package java.util.stream;
28 * An enum describing the known shape specializations for stream abstractions.
37 * streams and operations (i.e., if the output shape of a stream is compatible
40 * <p>Some APIs require you to specify both a generic type and a stream shape
H A DTerminalOp.java25 package java.util.stream;
30 * An operation in a stream pipeline that takes a stream as input and produces
31 * a result or side-effect. A {@code TerminalOp} has an input type and stream
34 * of the stream (such as short-circuiting or respecting encounter order; see
38 * of the operation relative to a given stream source and set of intermediate
56 * Gets the stream flags of the operation. Terminal operations may set a
57 * limited subset of the stream flags defined in {@link StreamOpFlag}, and
58 * these flags are combined with the previously combined stream and
63 * @return the stream flag
[all...]
H A DTripwire.java25 package java.util.stream;
34 * {@code java.util.stream} classes. The detection is turned on or off based on
35 * whether the system property {@code org.openjdk.java.util.stream.tripwire} is
49 private static final String TRIPWIRE_PROPERTY = "org.openjdk.java.util.stream.tripwire";
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
H A DIntermediateTestOp.java23 package java.util.stream;
H A DStreamOpFlagTestHelper.java23 package java.util.stream;
29 /** EnumSet containing stream flags */
H A DLambdaTestMode.java23 package java.util.stream;
44 * {@code org.openjdk.java.util.stream.sand.mode} is declared with a
54 Boolean.getBoolean("org.openjdk.java.util.stream.sand.mode");
/libcore/luni/src/main/native/
H A DZipUtilities.h30 z_stream stream; member in class:NativeZipStream
50 NativeZipStream* stream);
/libcore/ojluni/src/main/java/java/sql/
H A DSQLData.java87 * type from the given input stream. This is done
88 * by calling a method of the input stream to read each
100 * The JDBC driver initializes the input stream with a type map
102 * <code>SQLInput</code> reader method on the stream.
104 * @param stream the <code>SQLInput</code> object from which to read the data for
106 * @param typeName the SQL type name of the value on the data stream
113 void readSQL (SQLInput stream, String typeName) throws SQLException; argument
116 * Writes this object to the given SQL data stream, converting it back to
120 * to the given output stream. This is done by calling a
121 * method of the output stream t
136 writeSQL(SQLOutput stream) argument
[all...]
/libcore/ojluni/src/main/java/java/util/
H A DPropertyResourceBundle.java111 * that the input stream be encoded in ISO-8859-1. In that case, characters
128 * @param stream an InputStream that represents a property file
131 * @throws NullPointerException if <code>stream</code> is null
132 * @throws IllegalArgumentException if {@code stream} contains a
136 public PropertyResourceBundle (InputStream stream) throws IOException { argument
138 properties.load(stream);
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
H A DCountTest.java30 package org.openjdk.tests.java.util.stream;
32 import org.openjdk.testlib.java.util.stream.DoubleStreamTestDataProvider;
33 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
34 import org.openjdk.testlib.java.util.stream.LambdaTestHelpers;
35 import org.openjdk.testlib.java.util.stream.LongStreamTestDataProvider;
36 import org.openjdk.testlib.java.util.stream.OpTestCase;
37 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
38 import org.openjdk.testlib.java.util.stream.TestData;
41 import java.util.stream.DoubleStream;
42 import java.util.stream
[all...]
H A DPrimitiveAverageOpTest.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.DoubleStreamTestDataProvider;
27 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
28 import org.openjdk.testlib.java.util.stream.LongStreamTestDataProvider;
29 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
30 import org.openjdk.testlib.java.util.stream.TestData;
32 import java.util.stream.*;
H A 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
[all...]
H A 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()
[all...]
H A DStreamParSeqTest.java23 package org.openjdk.tests.java.util.stream;
28 import java.util.stream.Stream;
37 Stream<Integer> s = Arrays.asList(1, 2, 3, 4).stream().parallel();
H A 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)));
48 instances.add(countTo(1000).stream().mapToInt(i -> i).summaryStatistics());
54 assertEquals(stats.getSum(), countTo(1000).stream().mapToInt(i -> i).sum());
62 instances.add(countTo(1000).stream().collect(Collectors.summarizingLong(i -> i)));
63 instances.add(countTo(1000).stream().mapToLong(i -> i).summaryStatistics());
69 assertEquals(stats.getSum(), (long) countTo(1000).stream()
[all...]
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
H A DIntermediateTestOp.java23 package org.openjdk.testlib.java.util.stream;
25 import java.util.stream.AbstractPipeline;
H A DStreamOpFlagTestHelper.java23 package org.openjdk.testlib.java.util.stream;
26 import java.util.stream.BaseStream;
27 import java.util.stream.StreamOpFlag;
28 import java.util.stream.Stream;
32 /** EnumSet containing stream flags */
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/org/xml/sax/support/
H A DBrokenInputStream.java29 private InputStream stream; field in class:BrokenInputStream
33 public BrokenInputStream(InputStream stream, int offset) { argument
36 this.stream = stream;
47 return stream.read();
52 stream.close();
/libcore/luni/src/main/java/javax/xml/transform/stream/
H A DFilePathToURI.java18 package javax.xml.transform.stream;
H A DStreamResult.java20 package javax.xml.transform.stream;
40 "http://javax.xml.transform.stream.StreamResult/feature";
49 * Construct a StreamResult from a byte stream. Normally,
50 * a stream should be used rather than a reader, so that
61 * Construct a StreamResult from a character stream. Normally,
62 * a stream should be used rather than a reader, so that
66 * stream, such as when using a StringWriter.
94 * a stream should be used rather than a reader, so that
105 * Get the byte stream that was set with setOutputStream.
107 * @return The byte stream tha
[all...]
/libcore/ojluni/src/main/java/java/security/
H A DCertificate.java98 * Encodes the certificate to an output stream in a format that can
101 * @param stream the output stream to which to encode the
107 * @exception IOException if a stream exception occurs while
108 * trying to output the encoded certificate to the output stream.
113 public abstract void encode(OutputStream stream) argument
117 * Decodes a certificate from an input stream. The format should be
121 * @param stream the input stream from which to fetch the data
128 * the encoded certificate from the input stream
133 decode(InputStream stream) argument
[all...]

Completed in 5410 milliseconds

12345678