| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| StatelessTestOp.java | 23 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;
|
| StreamOpFlagTestHelper.java | 23 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 */
48 public static boolean isStreamOrdered(Stream<?> s) {
|
| /external/antlr/antlr-3.4/tool/src/test/java/org/antlr/test/ |
| TestBufferedTreeNodeStream.java | 44 public String toTokenTypeString(TreeNodeStream stream) {
45 return ((BufferedTreeNodeStream)stream).toTokenTypeString();
50 // stream has 7 real + 6 nav nodes
62 TreeNodeStream stream = newStream(r0); local
63 stream.consume(); // consume 101
64 stream.consume(); // consume DN
65 stream.consume(); // consume 102
66 stream.seek(7); // seek to 107
67 assertEquals(107, ((Tree)stream.LT(1)).getType());
68 stream.consume(); // consume 10
[all...] |
| /external/archive-patcher/shared/src/test/java/com/google/archivepatcher/shared/ |
| CountingOutputStreamTest.java | 34 private CountingOutputStream stream; field in class:CountingOutputStreamTest
59 stream = new CountingOutputStream(outBuffer);
64 Assert.assertEquals(0, stream.getNumBytesWritten());
69 stream.write(1);
70 Assert.assertEquals(1, stream.getNumBytesWritten());
71 stream.write(new byte[] {2, 3, 4});
72 Assert.assertEquals(4, stream.getNumBytesWritten());
73 stream.write(new byte[] {4, 5, 6, 7, 8}, 1, 3); // Write only {5, 6, 7}
74 Assert.assertEquals(7, stream.getNumBytesWritten());
83 stream = new CountingOutputStream(new NullStream())
[all...] |
| RandomAccessFileInputStreamTest.java | 39 private RandomAccessFileInputStream stream = null; field in class:RandomAccessFileInputStreamTest
72 stream = new RandomAccessFileInputStream(tempFile);
78 stream.close();
92 Assert.assertEquals(x, stream.read());
94 Assert.assertEquals(-1, stream.read());
103 int numRead = stream.read(buffer);
109 Assert.assertEquals(-1, stream.read(buffer, 0, 1));
115 Assert.assertEquals(0, stream.read(new byte[] {}, 0, -1));
124 int numRead = stream.read(buffer, 0, 2); // At most 2 bytes of the buffer can be used
130 Assert.assertEquals(-1, stream.read())
[all...] |
| /external/robolectric-shadows/robolectric/src/main/java/org/robolectric/internal/dependency/ |
| PropertiesDependencyResolver.java | 24 InputStream stream = propertiesFile.getInputStream(); local
25 properties.load(stream);
26 stream.close();
|
| /cts/apps/VpnApp/src/com/android/cts/vpnfirewall/ |
| Ipv4Packet.java | 42 public Ipv4Packet(DataInputStream stream) throws IOException {
43 int versionIhl = stream.readUnsignedByte();
47 type = stream.readUnsignedByte();
48 totalLength = stream.readUnsignedShort();
49 identification = stream.readUnsignedShort();
50 flagsAndOffset = stream.readUnsignedShort();
51 timeToLive = stream.readUnsignedByte();
52 protocol = stream.readUnsignedByte();
53 int checksum = stream.readUnsignedShort();
57 stream.read(address, 0, address.length)
97 DataOutputStream stream = new DataOutputStream(output); local
[all...] |
| /test/suite_harness/common/util/tests/src/com/android/compatibility/common/util/ |
| BusinessLogicTest.java | 246 FileOutputStream stream = new FileOutputStream(file); local
247 stream.write(blString.getBytes());
248 stream.flush();
249 stream.close();
|
| /external/conscrypt/common/src/main/java/org/conscrypt/ |
| OpenSSLRSAPublicKey.java | 177 private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
178 stream.defaultReadObject();
192 private void writeObject(ObjectOutputStream stream) throws IOException {
194 stream.defaultWriteObject();
|
| /external/easymock/src/org/easymock/internal/ |
| LegacyMatcherProvider.java | 72 private void readObject(java.io.ObjectInputStream stream)
74 stream.defaultReadObject();
75 Map<MethodSerializationWrapper, ArgumentsMatcher> map = (Map<MethodSerializationWrapper, ArgumentsMatcher>) stream
91 private void writeObject(java.io.ObjectOutputStream stream)
93 stream.defaultWriteObject();
100 stream.writeObject(map);
|
| /external/guava/guava/src/com/google/common/collect/ |
| EnumBiMap.java | 129 private void writeObject(ObjectOutputStream stream) throws IOException {
130 stream.defaultWriteObject();
131 stream.writeObject(keyType);
132 stream.writeObject(valueType);
133 Serialization.writeMap(this, stream);
138 private void readObject(ObjectInputStream stream)
140 stream.defaultReadObject();
141 keyType = (Class<K>) stream.readObject();
142 valueType = (Class<V>) stream.readObject();
146 Serialization.populateMap(this, stream);
[all...] |
| EnumHashBiMap.java | 111 private void writeObject(ObjectOutputStream stream) throws IOException {
112 stream.defaultWriteObject();
113 stream.writeObject(keyType);
114 Serialization.writeMap(this, stream);
119 private void readObject(ObjectInputStream stream)
121 stream.defaultReadObject();
122 keyType = (Class<K>) stream.readObject();
125 Serialization.populateMap(this, stream);
|
| EnumMultiset.java | 84 private void writeObject(ObjectOutputStream stream) throws IOException {
85 stream.defaultWriteObject();
86 stream.writeObject(type);
87 Serialization.writeMultiset(this, stream);
96 private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
97 stream.defaultReadObject();
99 Class<E> localType = (Class<E>) stream.readObject();
102 Serialization.populateMultiset(this, stream);
|
| HashMultimap.java | 123 private void writeObject(ObjectOutputStream stream) throws IOException {
124 stream.defaultWriteObject();
125 stream.writeInt(expectedValuesPerKey);
126 Serialization.writeMultimap(this, stream);
130 private void readObject(ObjectInputStream stream)
132 stream.defaultReadObject();
133 expectedValuesPerKey = stream.readInt();
134 int distinctKeys = Serialization.readCount(stream);
137 Serialization.populateMultimap(this, stream, distinctKeys);
|
| HashMultiset.java | 84 private void writeObject(ObjectOutputStream stream) throws IOException {
85 stream.defaultWriteObject();
86 Serialization.writeMultiset(this, stream);
90 private void readObject(ObjectInputStream stream)
92 stream.defaultReadObject();
93 int distinctElements = Serialization.readCount(stream);
96 Serialization.populateMultiset(this, stream, distinctElements);
|
| LinkedHashMultiset.java | 96 private void writeObject(ObjectOutputStream stream) throws IOException {
97 stream.defaultWriteObject();
98 Serialization.writeMultiset(this, stream);
102 private void readObject(ObjectInputStream stream)
104 stream.defaultReadObject();
105 int distinctElements = Serialization.readCount(stream);
108 Serialization.populateMultiset(this, stream, distinctElements);
|
| /external/jacoco/org.jacoco.core/src/org/jacoco/core/tools/ |
| ExecFileLoader.java | 47 * Reads all data from given input stream.
49 * @param stream
50 * Stream to read data from
52 * in case of problems while reading from the stream
54 public void load(final InputStream stream) throws IOException {
56 new BufferedInputStream(stream));
63 * Reads all data from given input stream.
68 * in case of problems while reading from the stream
71 final InputStream stream = new FileInputStream(file); local
73 load(stream);
[all...] |
| /external/javassist/src/main/javassist/bytecode/analysis/ |
| FramePrinter.java | 38 private final PrintStream stream; field in class:FramePrinter
43 public FramePrinter(PrintStream stream) {
44 this.stream = stream;
50 public static void print(CtClass clazz, PrintStream stream) {
51 (new FramePrinter(stream)).print(clazz);
78 stream.println("\n" + getMethodString(method));
103 stream.println(pos + ": " + InstructionPrinter.instructionString(iterator, pos, pool));
108 stream.println("--DEAD CODE--");
120 stream.print("stack [")
[all...] |
| /frameworks/base/graphics/java/android/graphics/ |
| BitmapRegionDecoder.java | 91 * Create a BitmapRegionDecoder from an input stream.
92 * The stream's position will be where ever it was after the encoded data
96 * @param is The input stream that holds the raw data to be decoded into a
146 InputStream stream = null; local
149 stream = new FileInputStream(pathName);
150 decoder = newInstance(stream, isShareable);
152 if (stream != null) {
154 stream.close();
|
| /frameworks/opt/net/wifi/tests/wifitests/src/com/android/server/wifi/hotspot2/anqp/ |
| DomainNameElementTest.java | 43 * Helper function for appending a Domain Name to an output stream.
45 * @param stream Stream to write to
49 private void appendDomain(ByteArrayOutputStream stream, String domain) throws IOException {
51 stream.write((byte) domainBytes.length);
52 stream.write(domainBytes);
62 ByteArrayOutputStream stream = new ByteArrayOutputStream(); local
64 appendDomain(stream, domain);
66 return stream.toByteArray();
|
| NAIRealmDataTestUtil.java | 87 ByteArrayOutputStream stream = new ByteArrayOutputStream(); local
89 stream.write((byte) realmData.length);
90 stream.write((byte) realmData.length >> 8);
91 stream.write(realmData);
92 return stream.toByteArray();
110 ByteArrayOutputStream stream = new ByteArrayOutputStream(); local
112 stream.write((byte) (utfEncoding ? NAIRealmData.NAI_ENCODING_UTF8_MASK : 0));
113 stream.write((byte) realmStrData.length);
114 stream.write(realmStrData);
115 stream.write((byte) 1); // EAP Method coun
[all...] |
| ThreeGPPNetworkElementTest.java | 70 ByteArrayOutputStream stream = new ByteArrayOutputStream(); local
72 stream.write((byte) version);
73 stream.write((byte) totalIeiSize);
75 stream.write(iei);
77 return stream.toByteArray();
|
| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| SequentialOpTest.java | 23 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;
39 import java.util.stream.Stream;
56 Supplier<Stream<Integer>>[] suppliers = new Supplier[] { () -> data.stream(), () -> data.parallelStream() };
57 UnaryOperator<Stream<Integer>>[] config
75 Stream<Integer> stream = config.apply(supp.get()); local
[all...] |
| /packages/apps/UnifiedEmail/src/com/android/mail/browse/ |
| EmlMessageLoader.java | 55 final InputStream stream; local
57 stream = resolver.openInputStream(mEmlFileUri);
66 mimeMessage = new MimeMessage(stream);
76 stream.close();
|
| /packages/apps/UnifiedEmail/src/org/apache/james/mime4j/decoder/ |
| QuotedPrintableInputStream.java | 31 * Performs Quoted-Printable decoding on an underlying stream.
40 private InputStream stream; field in class:QuotedPrintableInputStream
45 public QuotedPrintableInputStream(InputStream stream) {
46 this.stream = stream;
50 * Closes the underlying stream.
55 stream.close();
72 * Pulls bytes out of the underlying stream and places them in the
74 * underlying stream directly) to detect and filter out "transport
78 * @throws IOException Underlying stream threw IOException
[all...] |
