- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for Progress (0.19 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
* blast radius possible. If an HTTP/2 stream is active, canceling will cancel that stream but not * the other streams sharing its connection. But if the TLS handshake is still in progress then * canceling may break the entire connection. */ class RealCall( val client: OkHttpClient, /** The application's original request unadulterated by redirects or auth headers. */ val originalRequest: Request,
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/Dispatcher.kt
executableCalls.add(asyncCall) runningAsyncCalls.add(asyncCall) } isRunning = runningCallsCount() > 0 } // Avoid resubmitting if we can't logically progress // particularly because RealCall handles a RejectedExecutionException // by executing on the same thread. if (executorService.isShutdown) { for (i in 0 until executableCalls.size) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
if (journalRebuildRequired()) { cleanupQueue.schedule(cleanupTask) } return snapshot } /** Returns an editor for the entry named [key], or null if another edit is in progress. */ @Synchronized @Throws(IOException::class) @JvmOverloads fun edit( key: String, expectedSequenceNumber: Long = ANY_SEQUENCE_NUMBER, ): Editor? { initialize()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
fun readAndWriteOverlapsMaintainConsistency(parameters: Pair<FileSystem, Boolean>) { setUp(parameters.first, parameters.second) Assumptions.assumeFalse(windows) // Can't edit while a read is in progress. val v1Creator = cache.edit("k1")!! v1Creator.setString(0, "AAaa") v1Creator.setString(1, "BBbb") v1Creator.commit() cache["k1"]!!.use { snapshot1 ->
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/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
expected: String?, source: Source?, ) { val actual = source!!.buffer().readUtf8() assertThat(actual).isEqualTo(expected) } /** * Returns true when all work currently in progress by the watchdog have completed. This method * creates more work for the watchdog and waits for that work to be executed. When it is, we know * work that preceded this call is complete. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0)