- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for expectsContinue (0.22 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
if ("100-continue".equals(request.header("Expect"), ignoreCase = true)) { exchange.flushRequest() responseBuilder = exchange.readResponseHeaders(expectContinue = true) exchange.responseHeadersStart() invokeStartEvent = false } if (responseBuilder == null) { if (requestBody.isDuplex()) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/ExchangeCodec.kt
fun finishRequest() /** * Parses bytes of a response header from an HTTP transport. * * @param expectContinue true to return null if this is an intermediate response with a "100" * response code. Otherwise this method never returns null. */ @Throws(IOException::class) fun readResponseHeaders(expectContinue: Boolean): Response.Builder? @Throws(IOException::class) fun reportedContentLength(response: Response): Long
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
stream!!.getSink().close() } override fun readResponseHeaders(expectContinue: Boolean): Response.Builder? { val stream = stream ?: throw IOException("stream wasn't created") val headers = stream.takeHeaders(callerIsIdle = expectContinue) val responseBuilder = readHttp2HeadersList(headers, protocol) return if (expectContinue && responseBuilder.code == HTTP_CONTINUE) { null } else {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.9K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/SocketPolicy.kt
DISCONNECT_DURING_RESPONSE_BODY, DO_NOT_READ_REQUEST_BODY, FAIL_HANDSHAKE, SHUTDOWN_INPUT_AT_END, SHUTDOWN_OUTPUT_AT_END, STALL_SOCKET_AT_START, NO_RESPONSE, RESET_STREAM_AT_START, EXPECT_CONTINUE, CONTINUE_ALWAYS,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
} result.settings(settings) result.status = status result.headers(headers) result.trailers(trailers) result.socketPolicy = when (socketPolicy) { SocketPolicy.EXPECT_CONTINUE, SocketPolicy.CONTINUE_ALWAYS -> { result.add100Continue() KeepOpen } SocketPolicy.UPGRADE_TO_SSL_AT_END -> { result.inTunnel() KeepOpen }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
} fun responseHeadersStart() { eventListener.responseHeadersStart(call) } @Throws(IOException::class) fun readResponseHeaders(expectContinue: Boolean): Response.Builder? { try { val result = codec.readResponseHeaders(expectContinue) result?.initExchange(this) return result } catch (e: IOException) { eventListener.responseFailed(call, e) trackFailure(e)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.2K bytes - Viewed (0) -
platforms/core-execution/build-cache-http/src/main/java/org/gradle/caching/http/internal/HttpBuildCacheService.java
final URI uri = root.resolve(key.getHashCode()); HttpPut httpPut = new HttpPut(uri); if (useExpectContinue) { httpPut.setHeader(HTTP.EXPECT_DIRECTIVE, HTTP.EXPECT_CONTINUE); } httpPut.addHeader(HttpHeaders.CONTENT_TYPE, BUILD_CACHE_CONTENT_TYPE); requestCustomizer.customize(httpPut); httpPut.setEntity(new AbstractHttpEntity() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 04 14:13:12 UTC 2024 - 8K bytes - Viewed (0)