- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 271 for blocking (0.23 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
val pooled1 = planReusePooledConnection() if (pooled1 != null) return pooled1 // Attempt a deferred plan before new routes. if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst() // Do blocking calls to plan a route for a new connection. val connect = planConnect() // Now that we have a set of IP addresses, make another attempt at getting a connection from
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 12K bytes - Viewed (0) -
README.md
configured to fall back for broad connectivity. Using OkHttp is easy. Its request/response API is designed with fluent builders and immutability. It supports both synchronous blocking calls and async calls with callbacks. A well behaved user agent ------------------------- OkHttp follows modern HTTP specifications such as
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 28 07:33:49 UTC 2025 - 8.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt
* call this without consuming the complete response body, any remaining bytes in the response * body will be discarded before trailers are returned. * * If [Call.cancel] is called while this is blocking, this call will immediately throw. * * @throws IllegalStateException if the response is closed. * @throws IOException if the trailers cannot be loaded, such as if the network connection is * dropped.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 28 14:39:28 UTC 2025 - 18.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
return result; } /** * Following the contract of {@link AbstractQueuedSynchronizer} we create a private subclass to * hold the synchronizer. This synchronizer is used to implement the blocking and waiting calls * as well as to handle state changes in a thread-safe manner. The current state of the future * is held in the Sync state, and the lock is released whenever the state changes to {@link
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jan 30 16:59:10 UTC 2025 - 13.7K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Ascii.java
*/ public static final byte SYN = 22; /** * End of Transmission Block: A communication control character used to indicate the end of a * block of data for communication purposes. ETB is used for blocking data where the block * structure is not necessarily related to the processing format. * * @since 8.0 */ public static final byte ETB = 23; /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 21.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
* * @author Anthony Zana * @since 10.0 */ @GwtCompatible public final class Uninterruptibles { // Implementation Note: As of 3-7-11, the logic for each blocking/timeout // methods is identical, save for method being invoked. /** Invokes {@code latch.}{@link CountDownLatch#await() await()} uninterruptibly. */ @J2ktIncompatible @GwtIncompatible // concurrency
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java
} curr = succ; } break; } } // A heuristic for timed gets. If the remaining timeout is less than this, spin instead of // blocking. This value is what AbstractQueuedSynchronizer uses. private static final long SPIN_THRESHOLD_NANOS = 1000L; @VisibleForTesting static String atomicHelperTypeForTest() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 33.2K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
requests, responses, headers, and calls. It uses modern Java patterns like immutability and chained builders. The API now offers asynchronous callbacks in addition to synchronous blocking calls. #### API Changes * **New Request and Response types,** each with their own builder. There's also a `RequestBody` class to write the request body to the network and a
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 26.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractFutureState.java
} curr = succ; } break; } } // A heuristic for timed gets. If the remaining timeout is less than this, spin instead of // blocking. This value is what AbstractQueuedSynchronizer uses. private static final long SPIN_THRESHOLD_NANOS = 1000L; @VisibleForTesting static String atomicHelperTypeForTest() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 34.8K bytes - Viewed (0) -
docs/pt/docs/async.md
/// warning Você pode provavelmente pular isso. Esses são detalhes muito técnicos de como **FastAPI** funciona por baixo do capô. Se você tem certo conhecimento técnico (corrotinas, threads, blocking etc) e está curioso sobre como o FastAPI controla o `async def` vs normal `def`, vá em frente. /// ### Funções de operação de rota
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:56:21 UTC 2025 - 23.6K bytes - Viewed (0)