Searched defs:stream (Results 101 - 125 of 179) sorted by relevance

12345678

/libcore/ojluni/src/main/java/com/sun/security/cert/internal/x509/
H A DX509V1CertImpl.java92 * unmarshals an X.509 certificate from an input stream.
94 * @param in an input stream holding at least one certificate
304 private synchronized void writeObject(ObjectOutputStream stream) argument
307 stream.write(getEncoded());
313 private synchronized void readObject(ObjectInputStream stream) argument
317 getFactory().generateCertificate(stream);
/libcore/ojluni/src/main/java/java/security/
H A DKeyStoreSpi.java283 * Stores this keystore to the given output stream, and protects its
286 * @param stream the output stream to which this keystore is written.
295 public abstract void engineStore(OutputStream stream, char[] password) argument
324 * Loads the keystore from the given input stream.
332 * @param stream the input stream from which the keystore is loaded,
349 public abstract void engineLoad(InputStream stream, char[] password) argument
/libcore/ojluni/src/main/java/java/util/
H A DEnumSet.java439 private void readObject(java.io.ObjectInputStream stream) argument
/libcore/ojluni/src/main/java/java/util/stream/
H A DAbstractTask.java25 package java.util.stream;
32 * Abstract base class for most fork-join tasks used to implement stream ops.
77 * tasks managed by stream ops.
131 * @param helper The {@code PipelineHelper} describing the stream pipeline
H A DFindOps.java25 package java.util.stream;
38 * for an element in a stream pipeline, and terminates when it finds one.
52 * @param <T> the type of elements of the stream
100 * stream pipeline, and terminates when it finds one. Implements both
104 * @param <T> the output type of the stream pipeline
120 * @param shape stream shape of elements to search
245 * @param <P_IN> Input element type to the stream pipeline
246 * @param <P_OUT> Output element type from the stream pipeline
H A DForEachOps.java25 package java.util.stream;
40 * action for every element of a stream. Supported variants include unordered
62 * of a stream.
65 * stream
67 * @param <T> the type of the stream elements
81 * stream
96 * stream
111 * a stream
122 * A {@code TerminalOp} that evaluates a stream pipeline and sends the
125 * they will be sent independent of the stream'
[all...]
H A DMatchOps.java25 package java.util.stream;
37 * quantified predicate matching on the elements of a stream. Supported variants
73 * @param <T> the type of stream elements
74 * @param predicate the {@code Predicate} to apply to stream elements
103 * @param predicate the {@code Predicate} to apply to stream elements
132 * @param predicate the {@code Predicate} to apply to stream elements
162 * @param predicate the {@code Predicate} to apply to stream elements
191 * elements of a stream and determines whether all, any or none of those
194 * @param <T> the output type of the stream pipeline
204 * @param shape the output shape of the stream pipelin
[all...]
H A DNode.java25 package java.util.stream;
53 * contained in the leaf nodes. The use of {@code Node} within the stream
172 * @return the stream shape associated with this node
265 if (java.util.stream.Tripwire.ENABLED)
266 java.util.stream.Tripwire.trip(getClass(), "{0} calling Node.OfPrimitive.asArray");
H A DReduceOps.java25 package java.util.stream;
675 * A {@code TerminalOp} that evaluates a stream pipeline and sends the
680 * @param <T> the output type of the stream pipeline
689 * Create a {@code ReduceOp} of the specified stream shape which uses
692 * @param shape The shape of the stream pipeline
/libcore/ojluni/src/main/java/sun/net/www/http/
H A DKeepAliveCache.java224 private void writeObject(java.io.ObjectOutputStream stream) argument
229 private void readObject(java.io.ObjectInputStream stream) argument
283 private void writeObject(java.io.ObjectOutputStream stream) argument
288 private void readObject(java.io.ObjectInputStream stream) argument
/libcore/ojluni/src/main/java/sun/security/x509/
H A DX509Key.java294 * Encode SubjectPublicKeyInfo sequence on the DER output stream.
359 * Initialize an X509Key object from an input stream. The data on that
360 * input stream must be encoded using DER, obeying the X.509
375 * @param in an input stream with a DER-encoded X.509
410 private void writeObject(ObjectOutputStream stream) throws IOException { argument
411 stream.write(getEncoded());
418 private void readObject(ObjectInputStream stream) throws IOException { argument
420 decode(stream);
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
H A DStreamTestDataProvider.java23 package java.util.stream;
97 () -> new ArrayList<>(intsAsList).stream()));
H A DStreamTestScenario.java23 package java.util.stream;
37 * stream (as provided by the data source) to a new stream, and a sink to
39 * stream contents. The test driver will ensure that all scenarios produce
48 Stream<U> s = m.apply(data.stream());
61 for (U t : m.apply(data.stream()).collect(Collectors.toList())) {
71 for (Object t : m.apply(data.stream()).toArray()) {
77 // Wrap as stream, and iterate in pull mode
81 for (Iterator<U> seqIter = m.apply(data.stream()).iterator(); seqIter.hasNext(); )
86 // Wrap as stream, an
[all...]
/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/
H A DFlagOpTest.java23 package java.util.stream;
33 import static java.util.stream.LambdaTestHelpers.countTo;
H A DStreamOpFlagsTest.java23 package java.util.stream;
39 import static java.util.stream.Collectors.toList;
40 import static java.util.stream.StreamOpFlag.*;
119 = StreamOpFlagTestHelper.allStreamFlags().stream().map(StreamOpFlag::set).collect(toList());
138 = StreamOpFlagTestHelper.allStreamFlags().stream().map(StreamOpFlag::set).collect(toList());
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
H A DConcatTest.java24 package org.openjdk.tests.java.util.stream;
39 import java.util.stream.DoubleStream;
40 import java.util.stream.IntStream;
41 import java.util.stream.LongStream;
42 import java.util.stream.Stream;
44 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.*;
109 Stream<Integer> s1s = c1.stream();
110 Stream<Integer> s2s = c2.stream();
126 // concat stream cannot guarantee uniqueness
128 // concat stream canno
[all...]
H A DSliceOpTest.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;
36 import java.util.stream.Collectors;
37 import java.util.stream.DoubleStream;
38 import java.util.stream.IntStream;
39 import java.util.stream.LongStream;
40 import java.util.stream
[all...]
H A DSortedOpTest.java23 package org.openjdk.tests.java.util.stream;
27 import org.openjdk.testlib.java.util.stream.CollectorOps;
28 import org.openjdk.testlib.java.util.stream.OpTestCase;
29 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
30 import org.openjdk.testlib.java.util.stream.TestData;
31 import org.openjdk.testlib.java.util.stream.*;
40 import java.util.stream.BaseStream;
41 import java.util.stream.DoubleStream;
42 import java.util.stream.IntStream;
43 import java.util.stream
[all...]
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
H A DDoubleStreamTestScenario.java23 package org.openjdk.testlib.java.util.stream;
34 import org.openjdk.testlib.java.util.stream.FlagDeclaringOp;
36 import java.util.stream.*;
42 * stream (as provided by the data source) to a new stream, and a sink to
44 * stream contents. The test driver will ensure that all scenarios produce
53 DoubleStream s = m.apply(data.stream());
65 for (double t : m.apply(data.stream()).toArray()) {
74 for (PrimitiveIterator.OfDouble seqIter = m.apply(data.stream()).iterator(); seqIter.hasNext(); )
79 // Wrap as stream, an
[all...]
H A DIntStreamTestScenario.java23 package org.openjdk.testlib.java.util.stream;
33 import java.util.stream.*;
35 import org.openjdk.testlib.java.util.stream.FlagDeclaringOp;
41 * stream (as provided by the data source) to a new stream, and a sink to
43 * stream contents. The test driver will ensure that all scenarios produce
52 IntStream s = m.apply(data.stream());
64 for (int t : m.apply(data.stream()).toArray()) {
73 for (PrimitiveIterator.OfInt seqIter = m.apply(data.stream()).iterator(); seqIter.hasNext(); )
78 // Wrap as stream, an
[all...]
H A DLongStreamTestScenario.java23 package org.openjdk.testlib.java.util.stream;
33 import java.util.stream.*;
35 import org.openjdk.testlib.java.util.stream.FlagDeclaringOp;
41 * stream (as provided by the data source) to a new stream, and a sink to
43 * stream contents. The test driver will ensure that all scenarios produce
52 LongStream s = m.apply(data.stream());
64 for (long t : m.apply(data.stream()).toArray()) {
73 for (PrimitiveIterator.OfLong seqIter = m.apply(data.stream()).iterator(); seqIter.hasNext(); )
78 // Wrap as stream, an
[all...]
H A DStreamTestDataProvider.java23 package org.openjdk.testlib.java.util.stream;
31 import java.util.stream.SpinedBuffer;
32 import java.util.stream.Stream;
100 () -> new ArrayList<>(intsAsList).stream()));
H A DStreamTestScenario.java23 package org.openjdk.testlib.java.util.stream;
32 import java.util.stream.*;
34 import org.openjdk.testlib.java.util.stream.FlagDeclaringOp;
40 * stream (as provided by the data source) to a new stream, and a sink to
42 * stream contents. The test driver will ensure that all scenarios produce
51 Stream<U> s = m.apply(data.stream());
64 for (U t : m.apply(data.stream()).collect(Collectors.toList())) {
74 for (Object t : m.apply(data.stream()).toArray()) {
80 // Wrap as stream, an
[all...]
/libcore/support/src/test/java/org/apache/harmony/security/tests/support/
H A DMyKeyStore.java178 public void engineStore(OutputStream stream, char[] password) argument
180 if (!(stream instanceof ByteArrayOutputStream)) {
181 throw new IOException("Incorrect stream");
201 public void engineLoad(InputStream stream, char[] password) argument
H A DMyKeyStoreSpi.java129 public void engineStore(OutputStream stream, char[] password) argument
131 if (!(stream instanceof ByteArrayOutputStream)) {
132 throw new IOException("Incorrect stream");
134 if (((ByteArrayOutputStream) stream).size() == 0) {
135 throw new IOException("Incorrect stream size ");
142 public void engineLoad(InputStream stream, char[] password) argument

Completed in 1980 milliseconds

12345678