| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| SpliteratorTest.java | 23 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.LongStreamTestDataProvider;
30 import org.openjdk.testlib.java.util.stream.SpliteratorTestHelper;
31 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
|
| StreamLinkTest.java | 23 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.Collectors
[all...] |
| StreamParSeqTest.java | 23 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();
|
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| FlagDeclaringOp.java | 23 package org.openjdk.testlib.java.util.stream;
25 import java.util.stream.Sink;
26 import java.util.stream.StreamShape;
|
| LambdaTestMode.java | 23 package org.openjdk.testlib.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/support/src/test/java/tests/support/ |
| Support_Xml.java | 35 ByteArrayInputStream stream = new ByteArrayInputStream(xml.getBytes()); local
38 return builder.parse(stream);
|
| /ndk/tests/device/issue42891-boost-1_52/jni/boost/boost/test/utils/ |
| wrap_stringstream.hpp | 51 wrapped_stream& stream();
66 targ.stream() << t;
74 basic_wrap_stringstream<CharT>::stream() function in class:boost::basic_wrap_stringstream
123 targ.stream() << man;
133 targ.stream() << man;
143 targ.stream() << man;
|
| /system/weaved/buffet/ |
| http_transport_client.cc | 91 auto stream = brillo::MemoryStream::OpenCopyOf(data, nullptr); local
92 CHECK(stream->GetRemainingSize());
94 if (!request.AddRequestBody(std::move(stream), &cromeos_error)) {
|
| /toolchain/binutils/binutils-2.25/opcodes/ |
| moxie-dis.c | 31 static void *stream; variable
47 stream = info->stream;
69 fpr (stream, "%s", opcode->name);
72 fpr (stream, "%s\t%s", opcode->name,
76 fpr (stream, "%s\t%s, %s", opcode->name,
89 fpr (stream, "%s\t%s, 0x%x", opcode->name,
103 fpr (stream, "%s\t0x%x", opcode->name, imm);
116 fpr (stream, "%s\t", opcode->name);
122 fpr (stream, "%s\t(%s), %s", opcode->name
[all...] |
| /external/antlr/antlr-3.4/tool/src/test/java/org/antlr/test/ |
| TestTreeNodeStream.java | 35 /** Test the tree node stream. */
38 /** Build new stream; let's us override to test other streams. */
43 public String toTokenTypeString(TreeNodeStream stream) {
44 return ((CommonTreeNodeStream)stream).toTokenTypeString();
50 TreeNodeStream stream = newStream(t); local
52 String found = toNodesOnlyString(stream);
56 found = toTokenTypeString(stream);
67 TreeNodeStream stream = newStream(t); local
69 String found = toNodesOnlyString(stream);
73 found = toTokenTypeString(stream);
90 TreeNodeStream stream = newStream(root); local
107 TreeNodeStream stream = newStream(root); local
122 TreeNodeStream stream = newStream(root); local
136 TreeNodeStream stream = newStream(t); local
153 TreeNodeStream stream = newStream(t); local
181 TreeNodeStream stream = newStream(r0); local
212 TreeNodeStream stream = newStream(r0); local
257 TreeNodeStream stream = newStream(r0); local
296 TreeNodeStream stream = newStream(r0); local
319 TreeNodeStream stream = newStream(r0); local
354 TreeNodeStream stream = newStream(g); local
[all...] |
| /developers/build/prebuilts/gradle/NetworkConnect/Application/src/main/java/com/example/android/networkconnect/ |
| MainActivity.java | 119 InputStream stream = null; local
123 stream = downloadUrl(urlString);
124 str = readIt(stream, 500);
126 if (stream != null) {
127 stream.close();
135 * an input stream.
150 InputStream stream = conn.getInputStream(); local
151 return stream;
156 * @param stream InputStream containing HTML from targeted site.
162 private String readIt(InputStream stream, int len) throws IOException, UnsupportedEncodingException
[all...] |
| /developers/samples/android/connectivity/network/NetworkConnect/Application/src/main/java/com/example/android/networkconnect/ |
| MainActivity.java | 119 InputStream stream = null; local
123 stream = downloadUrl(urlString);
124 str = readIt(stream, 500);
126 if (stream != null) {
127 stream.close();
135 * an input stream.
150 InputStream stream = conn.getInputStream(); local
151 return stream;
156 * @param stream InputStream containing HTML from targeted site.
162 private String readIt(InputStream stream, int len) throws IOException, UnsupportedEncodingException
[all...] |
| /development/samples/browseable/NetworkConnect/src/com.example.android.networkconnect/ |
| MainActivity.java | 119 InputStream stream = null; local
123 stream = downloadUrl(urlString);
124 str = readIt(stream, 500);
126 if (stream != null) {
127 stream.close();
135 * an input stream.
150 InputStream stream = conn.getInputStream(); local
151 return stream;
156 * @param stream InputStream containing HTML from targeted site.
162 private String readIt(InputStream stream, int len) throws IOException, UnsupportedEncodingException
[all...] |
| /external/conscrypt/src/main/java/org/conscrypt/ |
| OpenSSLECPrivateKey.java | 249 private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
250 stream.defaultReadObject();
252 byte[] encoded = (byte[]) stream.readObject();
259 private void writeObject(ObjectOutputStream stream) throws IOException {
264 stream.defaultWriteObject();
265 stream.writeObject(getEncoded());
|
| OpenSSLECPublicKey.java | 153 private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
154 stream.defaultReadObject();
156 byte[] encoded = (byte[]) stream.readObject();
163 private void writeObject(ObjectOutputStream stream) throws IOException {
168 stream.defaultWriteObject();
169 stream.writeObject(getEncoded());
|
| OpenSSLRSAPrivateCrtKey.java | 278 private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
279 stream.defaultReadObject();
293 private void writeObject(ObjectOutputStream stream) throws IOException {
299 stream.defaultWriteObject();
|
| OpenSSLRSAPrivateKey.java | 284 private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
285 stream.defaultReadObject();
299 private void writeObject(ObjectOutputStream stream) throws IOException {
305 stream.defaultWriteObject();
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/data/ |
| HttpUrlFetcher.java | 25 private InputStream stream; field in class:HttpUrlFetcher
70 stream = urlConnection.getInputStream();
71 return stream;
89 if (stream != null) {
91 stream.close();
|
| /external/guava/guava/src/com/google/common/collect/ |
| ArrayListMultimap.java | 149 private void writeObject(ObjectOutputStream stream) throws IOException {
150 stream.defaultWriteObject();
151 stream.writeInt(expectedValuesPerKey);
152 Serialization.writeMultimap(this, stream);
156 private void readObject(ObjectInputStream stream)
158 stream.defaultReadObject();
159 expectedValuesPerKey = stream.readInt();
160 int distinctKeys = Serialization.readCount(stream);
163 Serialization.populateMultimap(this, stream, distinctKeys);
|
| TreeMultimap.java | 246 private void writeObject(ObjectOutputStream stream) throws IOException {
247 stream.defaultWriteObject();
248 stream.writeObject(keyComparator());
249 stream.writeObject(valueComparator());
250 Serialization.writeMultimap(this, stream);
255 private void readObject(ObjectInputStream stream)
257 stream.defaultReadObject();
258 keyComparator = checkNotNull((Comparator<? super K>) stream.readObject());
259 valueComparator = checkNotNull((Comparator<? super V>) stream.readObject());
261 Serialization.populateMultimap(this, stream);
[all...] |
| /external/guava/guava/src/com/google/common/hash/ |
| AbstractNonStreamingHashFunction.java | 74 * In-memory stream-based implementation of Hasher.
77 final ExposedByteArrayOutputStream stream; field in class:AbstractNonStreamingHashFunction.BufferingHasher
81 this.stream = new ExposedByteArrayOutputStream(expectedInputSize);
86 stream.write(b);
93 stream.write(bytes);
102 stream.write(bytes, off, len);
108 stream.write(s & BOTTOM_BYTE);
109 stream.write((s >>> 8) & BOTTOM_BYTE);
115 stream.write(i & BOTTOM_BYTE);
116 stream.write((i >>> 8) & BOTTOM_BYTE)
[all...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| Spdy3ConnectionTest.java | 78 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true); local
79 assertEquals(headerEntries("a", "android"), stream.getResponseHeaders());
80 assertStreamData("robot", stream.getSource());
81 BufferedSink out = Okio.buffer(stream.getSink());
107 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, false); local
109 assertEquals(headerEntries("b", "banana"), stream.getResponseHeaders());
154 @Override public void receive(FramedStream stream) throws IOException {
156 assertEquals(pushHeaders, stream.getRequestHeaders());
157 assertEquals(null, stream.getErrorCode());
158 stream.reply(headerEntries("b", "banana"), true)
[all...] |
| /external/sonic/ |
| Main.java | 70 AudioInputStream stream = AudioSystem.getAudioInputStream(new File("talking.wav")); local
71 AudioFormat format = stream.getFormat();
75 ((int)stream.getFrameLength()*format.getFrameSize()));
77 line.open(stream.getFormat());
79 runSonic(stream, line, speed, pitch, rate, volume, emulateChordPitch, quality,
|
| /external/vogar/src/vogar/ |
| XmlReportReader.java | 45 FileInputStream stream = null; local
47 stream = new FileInputStream(xmlReport);
51 parser.setInput(stream, "UTF-8");
60 if (stream != null) {
62 stream.close();
|
| /frameworks/base/core/java/android/util/ |
| AtomicFile.java | 122 * Call when you have successfully finished writing to the stream
125 * will return the new file stream.
140 * Call when you have failed for some reason at writing to the stream
142 * write stream, and roll back to the previous state of the file.
221 FileInputStream stream = openRead(); local
224 int avail = stream.available();
227 int amt = stream.read(data, pos, data.length-pos);
236 avail = stream.available();
244 stream.close();
|
