- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Access (0.47 sec)
-
regression-test/src/main/AndroidManifest.xml
package="okhttp.android.regression"> <uses-permission android:name="android.permission.INTERNET" /> <!-- For HttpEngine --> <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
XML - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Mar 23 11:14:34 GMT 2024 - 291 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
fun executeOn(executorService: ExecutorService) { client.dispatcher.assertThreadDoesntHoldLock() var success = false try { executorService.execute(this) success = true } catch (e: RejectedExecutionException) { failRejected(e) } finally { if (!success) { client.dispatcher.finished(this) // This call is no longer running! } } }
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/Cache.kt
import okio.Sink import okio.Source import okio.buffer /** * Caches HTTP and HTTPS responses to the filesystem so they may be reused, saving time and * bandwidth. * * The Cache instance must have exclusive access to the [directory], since the internal data structures * may cause corruption or runtime errors if not. It may however be shared amongst multiple OkHttpClient * instances. * * ## Cache Optimization *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0) -
CHANGELOG.md
* New: `QueueDispatcher.clear()` may be used to reset a MockWebServer instance. * New: `FileDescriptor.toRequestBody()` may be particularly useful for users of Android's Storage Access Framework. * Upgrade: [Kotlin 1.5.31][kotlin_1_5_31]. * Upgrade: [Okio 3.0.0][okio_3_0_0]. ## Version 5.0.0-alpha.2 _2021-01-30_
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
override fun connectTcp(): ConnectResult { check(rawSocket == null) { "TCP already connected" } var success = false // Tell the call about the connecting call so async cancels work. user.addPlanToCancel(this) try { user.connectStart(route) connectSocket() success = true return ConnectResult(plan = this) } catch (e: IOException) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
} server.enqueue(MockResponse(body = "Success!")) val credential = basic("jesse", "secret") client = client.newBuilder() .authenticator(RecordingOkAuthenticator(credential, null)) .build() executeSynchronously("/") .assertCode(200) .assertBody("Success!") } @Test fun doesNotAttemptAuthorization21Times() {
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/test/java/okhttp3/KotlinSourceModernTest.kt
import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.Assumptions.assumeFalse import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Disabled import org.junit.jupiter.api.Test /** * Access every type, function, and property from Kotlin to defend against unexpected regressions in * modern 4.0.x kotlin source-compatibility. */ @Suppress( "ASSIGNED_BUT_NEVER_ACCESSED_VARIABLE", "UNUSED_ANONYMOUS_PARAMETER",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 46.5K bytes - Viewed (4) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
evictAllConnections(pool) assertThat(pool.connectionCount()).isEqualTo(2) forceConnectionsToExpire(pool, expireTime) assertThat(pool.connectionCount()).isEqualTo(2) // Excess connections aren't removed until they idle out, even if no longer needed setPolicy(pool, address, ConnectionPool.AddressPolicy(1)) assertThat(pool.connectionCount()).isEqualTo(2)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
// Send messages until the client's outgoing buffer overflows! val message: ByteString = ByteString.of(*ByteArray(1024 * 1024)) var messageCount: Long = 0 while (true) { val success = webSocket.send(message) if (!success) break messageCount++ val queueSize = webSocket.queueSize() assertThat(queueSize).isBetween(0L, messageCount * message.size) // Expect to fail before enqueueing 32 MiB.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
// If the server returned an illegal server_max_window_bits, fail the web socket. if (serverMaxWindowBits != null && serverMaxWindowBits !in 8..15) return false // Success. return true } @Throws(IOException::class) internal fun checkUpgradeSuccess( response: Response, exchange: Exchange?, ) { if (response.code != 101) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0)