- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for stream (0.2 sec)
-
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
assertThat(URLConnection.getDefaultRequestProperty("X-setDefaultRequestProperty")).isNull() } /** * Reads `count` characters from the stream. If the stream is exhausted before `count` * characters can be read, the remaining characters are returned and the stream is closed. */ private fun readAscii( inputStream: InputStream, count: Int, ): String { val result = StringBuilder()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
istioctl/pkg/authz/testdata/configdump.yaml
}, "route": { "cluster": "InboundPassthroughClusterIpv4", "timeout": "0s", "max_stream_duration": { "max_stream_duration": "0s", "grpc_timeout_header_max": "0s" } }, "decorator": { "operation": ":0/*"
Others - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Wed Jun 21 14:20:23 GMT 2023 - 206.7K bytes - Viewed (2) -
okhttp/src/test/java/okhttp3/CallTest.kt
// If this succeeds, too many requests were made. executeSynchronously("/") .assertFailure(IOException::class.java) .assertFailureMatches( "stream was reset: CANCEL", "unexpected end of stream on " + server.url("/").redact(), ) } @RetryingTest(5) @Flaky fun recoverWhenRetryOnConnectionFailureIsFalse_HTTP2() { enableProtocol(Protocol.HTTP_2)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CacheTest.kt
testResponseCaching(TransferKind.CHUNKED) } @Test fun responseCachingAndInputStreamSkipWithNoLengthHeaders() { testResponseCaching(TransferKind.END_OF_STREAM) } /** * Skipping bytes in the input stream caused ResponseCache corruption. * http://code.google.com/p/android/issues/detail?id=8175 */ private fun testResponseCaching(transferKind: TransferKind) { val mockResponse =
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 108.6K bytes - Viewed (0) -
api/maven-api-model/src/main/mdo/maven.mdo
*/ public String toString() { return "PatternSet [" + "includes: {" + getIncludes().stream().collect(java.util.stream.Collectors.joining(", ")) + "}, " + "excludes: {" + getExcludes().stream().collect(java.util.stream.Collectors.joining(", ")) + "}]"; } ]]> </code> </codeSegment> </codeSegments> </class>
XML - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Tue Apr 23 13:29:46 GMT 2024 - 115.1K bytes - Viewed (0) -
fastapi/routing.py
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Tue Apr 02 02:48:51 GMT 2024 - 170.1K bytes - Viewed (0) -
cmd/object-handlers.go
case authTypeStreamingSigned, authTypeStreamingSignedTrailer: // Initialize stream signature verifier. rd, s3Err = newSignV4ChunkedReader(r, rAuthType == authTypeStreamingSignedTrailer) if s3Err != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL) return } case authTypeStreamingUnsignedTrailer: // Initialize stream chunked reader with optional trailers.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 125K bytes - Viewed (0) -
fastapi/applications.py
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Tue Apr 02 02:48:51 GMT 2024 - 172.2K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Maps.java
* * <p><b>Note:</b> on Java 8+, it is usually better to use streams. For example: * * <pre>{@code * import static com.google.common.collect.ImmutableMap.toImmutableMap; * ... * ImmutableMap<String, Color> colorForName = * allColors.stream().collect(toImmutableMap(c -> c.toString(), c -> c)); * }</pre> *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 24 19:38:27 GMT 2024 - 159.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* {@link #withoutCloser(AsyncFunction)} * </ul> * * <p>Example usage: * * <pre>{@code * // Fall back to a secondary input stream in case of IOException. * ClosingFuture<InputStream> inputFuture = * firstInputFuture.catchingAsync( * IOException.class, (closer, x) -> secondaryInputStreamClosingFuture(), executor); * }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 98.5K bytes - Viewed (0)