Home
last modified time | relevance | path

Searched refs:getInputStream (Results 1 – 25 of 315) sorted by relevance

12345678910>>...13

/external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/output/
DMockSocketConnectionTest.java83 a.getInputStream(); in testGetInputStreamOnClosedSocket()
88 final InputStream in = a.getInputStream(); in testReadOnClosedSocket()
95 final InputStream in = a.getInputStream(); in testReadOnClosedSocketAsync()
128 final InputStream in = a.getInputStream(); in testContents()
151 final InputStream in = a.getInputStream(); in testWaitForContents()
168 final InputStream in = a.getInputStream(); in testCloseOtherSocket()
174 final InputStream in = a.getInputStream(); in testCloseOtherSocketAsync()
/external/mockwebserver/src/test/java/com/google/mockwebserver/
DMockWebServerTest.java113 InputStream in = connection.getInputStream(); in testRegularResponse()
132 InputStream in = connection.getInputStream(); in testRedirect()
160 InputStream in = connection.getInputStream(); in testDispatchBlocksWaitingForEnqueue()
173 InputStream in = connection.getInputStream(); in testNonHexadecimalChunkSize()
192 InputStream in = urlConnection.getInputStream(); in testResponseTimeout()
203 InputStream in2 = urlConnection2.getInputStream(); in testResponseTimeout()
219 server.getUrl("/a").openConnection().getInputStream(); in testDisconnectAtStart()
223 server.getUrl("/b").openConnection().getInputStream(); // Should succeed. in testDisconnectAtStart()
231 InputStream in = server.getUrl("/").openConnection().getInputStream(); in testStreamingResponseBody()
/external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/
DMockWebServerTest.java89 InputStream in = connection.getInputStream(); in regularResponse()
107 InputStream in = connection.getInputStream(); in redirect()
133 InputStream in = connection.getInputStream(); in dispatchBlocksWaitingForEnqueue()
145 InputStream in = connection.getInputStream(); in nonHexadecimalChunkSize()
162 InputStream in = urlConnection.getInputStream(); in responseTimeout()
173 InputStream in2 = urlConnection2.getInputStream(); in responseTimeout()
188 server.getUrl("/a").openConnection().getInputStream(); in disconnectAtStart()
191 server.getUrl("/b").openConnection().getInputStream(); // Should succeed. in disconnectAtStart()
206 InputStream in = connection.getInputStream(); in throttleRequest()
226 InputStream in = connection.getInputStream();
[all …]
/external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/net/
DExcludedProxyTest.java52 conn1.getInputStream(); in test_usingProxy()
59 conn3.getInputStream(); in test_usingProxy()
79 InputStream is2 = conn2.getInputStream(); in test_usingProxy()
102 InputStream is = conn4.getInputStream(); in test_usingProxy()
128 s.getInputStream(); in test_Constructor()
145 s.getInputStream(); in test_Constructor()
181 InputStream is = conn.getInputStream(); in test_openConnectionLjava_net_Proxy()
/external/apache-commons-compress/src/test/java/org/apache/commons/compress/archivers/zip/
DZipFileTest.java183 i = zf.getInputStream(ze); in testReadingOfStoredEntry()
272 assertNotNull(zf.getInputStream(ze)); in testDuplicateEntry()
277 assertNotNull(zf.getInputStream(entry)); in testDuplicateEntry()
302 IOUtils.toByteArray(zf.getInputStream(test))); in testUnshrinking()
310 IOUtils.toByteArray(zf.getInputStream(test))); in testUnshrinking()
328 IOUtils.toByteArray(zf.getInputStream(ze))); in testReadingOfFirstStoredEntry()
339 assertArrayEquals(expected, IOUtils.toByteArray(zf.getInputStream(ze))); in testUnzipBZip2CompressedEntry()
353 content.put(entry.getName(), IOUtils.toByteArray(zf.getInputStream(entry))); in testConcurrentReadSeekable()
383 content.put(entry.getName(), IOUtils.toByteArray(zf.getInputStream(entry))); in testConcurrentReadFile()
514 try (InputStream stream = zf.getInputStream(inflatedEntry)) { in testEntryAlignment()
[all …]
/external/apache-commons-bcel/src/main/java/org/apache/bcel/util/
DClassPath.java187 public InputStream getInputStream( final String name ) throws IOException { in getInputStream() method in ClassPath
188 return getInputStream(name.replace('.', '/'), ".class"); in getInputStream()
199 public InputStream getInputStream( final String name, final String suffix ) throws IOException { in getInputStream() method in ClassPath
209 return getClassFile(name, suffix).getInputStream(); in getInputStream()
312 try (InputStream is = getInputStream(name, suffix)) { in getBytes()
373 InputStream getInputStream() throws IOException; in getInputStream() method
435 public InputStream getInputStream() throws IOException { in getClassFile()
499 return (entry != null) ? zip.getInputStream(entry) : null;
516 public InputStream getInputStream() throws IOException {
517 return zip.getInputStream(entry);
/external/xz-java/src/org/tukaani/xz/
DFilterOptions.java90 public InputStream getInputStream(InputStream in) throws IOException { in getInputStream() method in FilterOptions
91 return getInputStream(in, ArrayCache.getDefaultCache()); in getInputStream()
98 public abstract InputStream getInputStream( in getInputStream() method in FilterOptions
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
DURLConnectionTest.java231 connection.getInputStream().close(); in responseHeaders()
324 connection.getInputStream().close(); in getErrorStreamOnSuccessfulRequest()
347 c1.getInputStream().close(); in bug2939()
348 c2.getInputStream().close(); in bug2939()
511 conn.getInputStream(); in getResponseCodeNoResponseBody()
596 readAscii(connection2.getInputStream(), Integer.MAX_VALUE); in connectViaHttpsReusingConnectionsDifferentFactories()
681 connection.getInputStream(); in connectViaHttpsToUntrustedServer()
727 readAscii(client.open(server.getUrl("/")).getInputStream(), 5); in contentDisagreesWithContentLengthHeaderBodyTooShort()
804 readAscii(client.open(server.getUrl("/")).getInputStream(), 5); in contentDisagreesWithChunkedHeaderBodyTooShort()
1022 InputStream in = connection.getInputStream(); in disconnectedConnection()
[all …]
/external/apache-commons-compress/src/main/java/org/apache/commons/compress/changes/
DChangeSetPerformer.java157 copyStream(entryIterator.getInputStream(), out, entry); in perform()
237 InputStream getInputStream() throws IOException; in getInputStream() method
256 public InputStream getInputStream() { in getInputStream() method in ChangeSetPerformer.ArchiveInputStreamIterator
280 public InputStream getInputStream() throws IOException { in getInputStream() method in ChangeSetPerformer.ZipFileIterator
281 return in.getInputStream(current); in getInputStream()
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
DHttpOverSpdyTest.java115 assertEquals(-1, connection.getInputStream().read()); in emptyResponse()
188 assertEquals("ABC", readAscii(connection1.getInputStream(), 3)); in spdyConnectionReuse()
189 assertEquals("GHI", readAscii(connection2.getInputStream(), 3)); in spdyConnectionReuse()
190 assertEquals("DEF", readAscii(connection1.getInputStream(), 3)); in spdyConnectionReuse()
191 assertEquals("JKL", readAscii(connection2.getInputStream(), 3)); in spdyConnectionReuse()
223 assertEquals("Successful auth!", readAscii(connection.getInputStream(), Integer.MAX_VALUE)); in authenticate()
252 InputStream in = connection.getInputStream(); in readAfterLastByte()
303 readAscii(connection.getInputStream(), Integer.MAX_VALUE); in readTimeoutOnSlowConnection()
363 InputStream in1 = connection1.getInputStream(); in responseCachedWithoutConsumingFullBody()
368 InputStream in2 = connection2.getInputStream(); in responseCachedWithoutConsumingFullBody()
[all …]
/external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/
DShadowImageDecoder.java44 InputStream inputStream = getInputStream(); in ImgStream()
56 protected abstract InputStream getInputStream(); in getInputStream() method in ShadowImageDecoder.ImgStream
136 protected InputStream getInputStream() { in ImageDecoder_nCreateInputStream()
153 protected InputStream getInputStream() {
170 protected InputStream getInputStream() {
182 protected InputStream getInputStream() {
200 final InputStream stream = imgStream.getInputStream();
/external/exoplayer/tree/library/dash/src/test/java/com/google/android/exoplayer2/source/dash/manifest/
DDashManifestParserTest.java63 TestUtil.getInputStream(ApplicationProvider.getApplicationContext(), SAMPLE_MPD)); in parseMediaPresentationDescription()
66 TestUtil.getInputStream( in parseMediaPresentationDescription()
76 TestUtil.getInputStream( in parseMediaPresentationDescription_segmentTemplate()
108 TestUtil.getInputStream( in parseMediaPresentationDescription_eventStream()
178 TestUtil.getInputStream(ApplicationProvider.getApplicationContext(), SAMPLE_MPD)); in parseMediaPresentationDescription_programInformation()
191 TestUtil.getInputStream( in parseMediaPresentationDescription_labels()
206 TestUtil.getInputStream(ApplicationProvider.getApplicationContext(), SAMPLE_MPD_TEXT)); in parseMediaPresentationDescription_text()
235 TestUtil.getInputStream( in parseMediaPresentationDescription_trickPlay()
460 TestUtil.getInputStream( in parsePeriodAssetIdentifier()
/external/jacoco/org.jacoco.core/src/org/jacoco/core/instr/
DInstrumenter.java192 instrument(detector.getInputStream(), output, name); in instrumentAll()
195 return instrumentZip(detector.getInputStream(), output, name); in instrumentAll()
197 return instrumentGzip(detector.getInputStream(), output, name); in instrumentAll()
199 return instrumentPack200(detector.getInputStream(), output, name); in instrumentAll()
201 copy(detector.getInputStream(), output, name); in instrumentAll()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DProxyTest.java72 DataInputStream clientIn = new DataInputStream(client.getInputStream()); in smallLatency()
102 DataInputStream clientIn = new DataInputStream(client.getInputStream()); in bigLatency()
134 DataInputStream clientIn = new DataInputStream(client.getInputStream()); in smallBandwidth()
158 DataInputStream clientIn = new DataInputStream(client.getInputStream()); in largeBandwidth()
220 DataInputStream serverIn = new DataInputStream(rcv.getInputStream());
/external/proguard/src/proguard/io/
DRenamedDataEntry.java59 public InputStream getInputStream() throws IOException in getInputStream() method in RenamedDataEntry
61 return dataEntry.getInputStream(); in getInputStream()
/external/apache-harmony/support/src/test/java/tests/support/
DSupport_HttpSocket.java38 public InputStream getInputStream() throws IOException { in getInputStream() method in Support_HttpSocket
40 return instance.getInputStream(); in getInputStream()
DSupport_URLConnector.java52 public InputStream getInputStream() throws IOException { in getInputStream() method in Support_URLConnector
57 return instance.getInputStream(); in getInputStream()
/external/bouncycastle/bcpkix/src/main/java/org/bouncycastle/cms/
DRecipientOperator.java27 public InputStream getInputStream(InputStream dataIn) in getInputStream() method in RecipientOperator
31 return ((InputDecryptor)operator).getInputStream(dataIn); in getInputStream()
/external/exoplayer/tree/library/smoothstreaming/src/test/java/com/google/android/exoplayer2/source/smoothstreaming/manifest/
DSsManifestParserTest.java39 TestUtil.getInputStream(ApplicationProvider.getApplicationContext(), SAMPLE_ISMC_1)); in parseSmoothStreamingManifest()
42 TestUtil.getInputStream(ApplicationProvider.getApplicationContext(), SAMPLE_ISMC_2)); in parseSmoothStreamingManifest()
/external/jacoco/org.jacoco.core/src/org/jacoco/core/analysis/
DAnalyzer.java192 analyzeClass(detector.getInputStream(), location); in analyzeAll()
195 return analyzeZip(detector.getInputStream(), location); in analyzeAll()
197 return analyzeGzip(detector.getInputStream(), location); in analyzeAll()
199 return analyzePack200(detector.getInputStream(), location); in analyzeAll()
/external/desugar/java/com/google/devtools/build/android/desugar/io/
DZipInputFileProvider.java55 public InputStream getInputStream(String filename) throws IOException { in getInputStream() method in ZipInputFileProvider
56 return zipFile.getInputStream(zipFile.getEntry(filename)); in getInputStream()
/external/caliper/caliper/src/main/java/com/google/caliper/bridge/
DOpenedSocket.java59 ObjectInputStream input = new ObjectInputStream(getInputStream(socket)); in fromSocket()
171 private static InputStream getInputStream(final Socket socket) throws IOException {
172 final InputStream delegate = socket.getInputStream();
/external/apache-commons-bcel/src/test/java/org/apache/bcel/
DBCELBenchmark.java77 byte[] bytes = IOUtils.toByteArray(jar.getInputStream(entry));
89 byte[] bytes = IOUtils.toByteArray(jar.getInputStream(entry));
103 byte[] bytes = IOUtils.toByteArray(jar.getInputStream(entry));
/external/conscrypt/common/src/test/java/org/conscrypt/javax/net/ssl/
DSSLSocketTest.java200 readFully(client.getInputStream(), clientFromServer); in test_SSLSocket_getSupportedCipherSuites_connect()
205 readFully(server.getInputStream(), serverFromClient); in test_SSLSocket_getSupportedCipherSuites_connect()
212 int value = server.getInputStream().read(); in test_SSLSocket_getSupportedCipherSuites_connect()
220 int value = client.getInputStream().read(); in test_SSLSocket_getSupportedCipherSuites_connect()
246 assertEquals(1, pair.server.getInputStream().read()); in test_SSLSocket_getInputStream_available()
247 assertTrue(pair.server.getInputStream().available() > 0); in test_SSLSocket_getInputStream_available()
248 assertEquals(3, pair.server.getInputStream().read(new byte[4])); in test_SSLSocket_getInputStream_available()
249 assertEquals(0, pair.server.getInputStream().available()); in test_SSLSocket_getInputStream_available()
255 assertEquals(1, pair.client.getInputStream().read()); in test_SSLSocket_getInputStream_available()
256 assertTrue(pair.client.getInputStream().available() > 0); in test_SSLSocket_getInputStream_available()
[all …]
/external/conscrypt/repackaged/common/src/test/java/com/android/org/conscrypt/javax/net/ssl/
DSSLSocketTest.java204 readFully(client.getInputStream(), clientFromServer); in test_SSLSocket_getSupportedCipherSuites_connect()
209 readFully(server.getInputStream(), serverFromClient); in test_SSLSocket_getSupportedCipherSuites_connect()
216 int value = server.getInputStream().read(); in test_SSLSocket_getSupportedCipherSuites_connect()
224 int value = client.getInputStream().read(); in test_SSLSocket_getSupportedCipherSuites_connect()
250 assertEquals(1, pair.server.getInputStream().read()); in test_SSLSocket_getInputStream_available()
251 assertTrue(pair.server.getInputStream().available() > 0); in test_SSLSocket_getInputStream_available()
252 assertEquals(3, pair.server.getInputStream().read(new byte[4])); in test_SSLSocket_getInputStream_available()
253 assertEquals(0, pair.server.getInputStream().available()); in test_SSLSocket_getInputStream_available()
259 assertEquals(1, pair.client.getInputStream().read()); in test_SSLSocket_getInputStream_available()
260 assertTrue(pair.client.getInputStream().available() > 0); in test_SSLSocket_getInputStream_available()
[all …]

12345678910>>...13