- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 73 for ends (8.93 sec)
-
docs/features/events.md
![Events Diagram](../assets/images/******@****.***) ### Events with Retries and Follow-Ups
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 7.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
fileOperator.write(FILE_HEADER_SIZE + upstreamSize, metadataBuffer, metadata.size.toLong()) } @Throws(IOException::class) fun commit(upstreamSize: Long) { // Write metadata to the end of the file. writeMetadata(upstreamSize) file!!.channel.force(false) // Once everything else is in place we can swap the dirty header for a clean one.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
private set private var timeoutEarlyExit = false /** * This is the same value as [exchange], but scoped to the execution of the network interceptors. * The [exchange] field is assigned to null when its streams end, which may be before or after the * network interceptors return. */ internal var interceptorScopedExchange: Exchange? = null private set
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
} override fun cancel() { exchange.cancel() } } } override fun route(): Route = route override fun cancel() { // Close the raw socket so we don't end up doing synchronous I/O. rawSocket?.closeQuietly() } override fun socket(): Socket = socket!! /** Returns true if this connection is ready to host new streams. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/HttpUrl.kt
* segments `["a", "b"]` build "/a/b" and the segments `["a", "b", ""]` build "/a/b/". * * If a path's last segment is the empty string then the path ends with "/". This class always * builds non-empty paths: if the path is omitted it defaults to "/". The default path's segment * list is a single empty string: `[""]`. * * ### Query *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 63.5K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/CookieTest.kt
assertThat(cookie.matches("http://www.example.com".toHttpUrl())).isTrue() assertThat(cookie.matches("http://square.com".toHttpUrl())).isFalse() } /** Ignore the entire attribute if the domain ends with `.`. */ @Test fun domainIgnoredWithTrailingDot() { val cookie = parse(url, "a=b; domain=example.com.") assertThat(cookie!!.matches("http://example.com".toHttpUrl())).isTrue()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 24.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
fun requestBodyThrowsUnrelatedToNetwork_HTTP2() { enableProtocol(Protocol.HTTP_2) requestBodyThrowsUnrelatedToNetwork() } /** * This test cancels the call just after the response body ends. In effect we end up with a * connection that returns to the connection pool with the underlying socket closed. This relies * on an implementation detail so it might not be a valid test case in the future. */ @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
import okhttp3.internal.format import okhttp3.internal.http2.Http2.CONNECTION_PREFACE import okhttp3.internal.http2.Http2.FLAG_ACK import okhttp3.internal.http2.Http2.FLAG_END_HEADERS import okhttp3.internal.http2.Http2.FLAG_END_STREAM import okhttp3.internal.http2.Http2.FLAG_NONE import okhttp3.internal.http2.Http2.INITIAL_MAX_FRAME_SIZE import okhttp3.internal.http2.Http2.TYPE_CONTINUATION
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/SocketPolicy.kt
enum class SocketPolicy { SHUTDOWN_SERVER_AFTER_RESPONSE, KEEP_OPEN, DISCONNECT_AT_END, UPGRADE_TO_SSL_AT_END, DISCONNECT_AT_START, DISCONNECT_AFTER_REQUEST, DISCONNECT_DURING_REQUEST_BODY, 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,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/tls/HostnameVerifierTest.kt
815CLpJZNcYwiYwGy/CVQ7w2TnXlG+mraZOz+owr+cL6J/ZesbdEWfjoS1+cUEhE HwlNrAu8jlZ2UqSgskSWlhYdMTAP9CPHiUv9N7FcT58Itv/I4fKREINQYjDpvQcx SaTYb9dr5sB4WLNglk7zxDtM80H518VvihTcP7FHL+Gn6g4j5fkI98+S -----END CERTIFICATE----- """.trimIndent(), ) assertThat(verifier.verify("foo.com", session)).isFalse() assertThat(verifier.verify("a.foo.com", session)).isFalse()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 40.3K bytes - Viewed (0)