- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 97 for Hafner (6.75 sec)
-
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
return when (val socketPolicy = socketPolicy) { SocketPolicy.SHUTDOWN_SERVER_AFTER_RESPONSE -> ShutdownServerAfterResponse SocketPolicy.KEEP_OPEN -> KeepOpen SocketPolicy.DISCONNECT_AT_END -> DisconnectAtEnd SocketPolicy.DISCONNECT_AT_START -> DisconnectAtStart SocketPolicy.DISCONNECT_AFTER_REQUEST -> DisconnectAfterRequest SocketPolicy.DISCONNECT_DURING_REQUEST_BODY -> DisconnectDuringRequestBody
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
taskFaker.runNextTask() // The in-flight editor can still write after a trim failure. inFlightEditor.setString(0, "cc") inFlightEditor.setString(1, "cc") inFlightEditor.commit() // Confirm the committed values are present after a successful cache trim. filesystem.setFaultyDelete(cacheDir / "a.0", false) taskFaker.runNextTask()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
// Some number of tests will report here, but not fail due to this delay. println("Delaying to avoid flakes") Thread.sleep(500L) println("After delay: " + connectionPool.connectionCount()) } connectionPool.evictAll() assertEquals(0, connectionPool.connectionCount()) { "Still ${connectionPool.connectionCount()} connections open"
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/AsyncDns.kt
} latch.countDown() } }, ) } latch.await() // No mutations should be possible after this point if (allAddresses.isEmpty()) { val first = allExceptions.firstOrNull() ?: UnknownHostException("No results for $hostname") allExceptions.drop(1).forEach {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 3.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
} // Close the writer to release its resources (such as deflaters). ignoreIoExceptions { writer.close() } // Close the socket to break out the reader thread, which will clean up after itself. ignoreIoExceptions { socket.close() } // Release the threads. writerQueue.shutdown() pushQueue.shutdown() settingsListenerQueue.shutdown() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
val dispatcher: Dispatcher = builder.dispatcher /** * Returns an immutable list of interceptors that observe the full span of each call: from before * the connection is established (if any) until after the response source is selected (either the * origin server, cache, or both). */ @get:JvmName("interceptors") val interceptors: List<Interceptor> = builder.interceptors.toImmutableList() /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
okhttp/src/test/resources/web-platform-test-toascii.json
Json - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 5.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt
internal const val OPCODE_FLAG_CONTROL = 8 /** * Byte 1 flag for whether the payload data is masked. * * If this flag is set, the next four * bytes represent the mask key. These bytes appear after any additional bytes specified by [B1_MASK_LENGTH]. */ internal const val B1_FLAG_MASK = 128 /** * Byte 1 mask for the payload length. * * If this value is [PAYLOAD_SHORT], the next two
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/HeadersJvmTest.kt
.add("foo : bak") // Name trailing whitespace is trimmed. .add("\tkey\t:\tvalue\t") // '\t' also counts as whitespace .add("ping: pong ") // Value whitespace is trimmed. .add("kit:kat") // Space after colon is not required. .build() assertThat(headers.values("foo")).containsExactly("bar", "baz", "bak") assertThat(headers.values("key")).containsExactly("value")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallKotlinTest.kt
assertThat(suppressed).isInstanceOf(IOException::class.java) assertThat(suppressed).isNotSameAs(expected) } } } /** Confirm suppressed exceptions that occur after connecting are returned. */ @Test fun httpExceptionsAreReturnedAsSuppressed() { server.enqueue(MockResponse(socketPolicy = DisconnectAtStart)) server.enqueue(MockResponse(socketPolicy = DisconnectAtStart))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 8.4K bytes - Viewed (0)