- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 323 for Enqueue (0.06 sec)
-
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
* try (Response response = call.execute()) { * ... // Use the response. * } * ``` * * You can use a similar block for asynchronous calls: * * ```java * Call call = client.newCall(request); * call.enqueue(new Callback() { * public void onResponse(Call call, Response response) throws IOException { * try (ResponseBody responseBody = response.body()) { * ... // Use the response. * } * } *
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.7K bytes - Viewed (0) -
mockwebserver-deprecated/api/mockwebserver.api
public final fun -deprecated_requestCount ()I public final fun -deprecated_serverSocketFactory (Ljavax/net/ServerSocketFactory;)V public fun <init> ()V public fun close ()V public final fun enqueue (Lokhttp3/mockwebserver/MockResponse;)V public final fun getBodyLimit ()J public final fun getDelegate ()Lmockwebserver3/MockWebServer; public final fun getDispatcher ()Lokhttp3/mockwebserver/Dispatcher;
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jul 22 12:28:51 UTC 2023 - 10.2K bytes - Viewed (0) -
mockwebserver/api/mockwebserver3.api
} public final class mockwebserver3/MockWebServer : java/io/Closeable { public static final field Companion Lmockwebserver3/MockWebServer$Companion; public fun <init> ()V public fun close ()V public final fun enqueue (Lmockwebserver3/MockResponse;)V public final fun getBodyLimit ()J public final fun getDispatcher ()Lmockwebserver3/Dispatcher; public final fun getHostName ()Ljava/lang/String;
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 03 21:59:45 UTC 2023 - 12.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
} }, directExecutor())); thingToCancel[0] = serializer.submit(Callables.returning(null), directExecutor()); results.add(thingToCancel[0]); // Enqueue more than enough tasks to force reentrancy. for (int i = 0; i < 5; i++) { results.add(serializer.submit(Callables.returning(null), directExecutor())); } manualExecutorTask[0].run();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.7K bytes - Viewed (0) -
tensorflow/c/eager/c_api.h
// the size of 'retvals' is less than the number of outputs. This call sets // *num_retvals to the number of outputs. // // If async execution is enabled, the call may simply enqueue the execution // and return "non-ready" handles in `retvals`. Note that any handles contained // in 'op' should not be mutated till the kernel execution actually finishes. //
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Thu Apr 27 21:07:00 UTC 2023 - 22.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
ReferenceEntry<Object, Object> entry = segment.getEntry(keyOne, hashOne); @SuppressWarnings("unchecked") Reference<Object> reference = (Reference<Object>) entry; reference.enqueue(); map.put(keyTwo, valueTwo); assertFalse(map.containsKey(keyOne)); assertFalse(map.containsValue(valueOne)); assertNull(map.get(keyOne)); assertEquals(1, map.size());
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 110.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
ReferenceEntry<Object, Object> entry = segment.getEntry(keyOne, hashOne); @SuppressWarnings("unchecked") Reference<Object> reference = (Reference<Object>) entry; reference.enqueue(); map.put(keyTwo, valueTwo); assertFalse(map.containsKey(keyOne)); assertFalse(map.containsValue(valueOne)); assertNull(map.get(keyOne)); assertEquals(1, map.size());
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 112.3K bytes - Viewed (0) -
docs/recipes.md
private val client = OkHttpClient() fun run() { val request = Request.Builder() .url("http://publicobject.com/helloworld.txt") .build() client.newCall(request).enqueue(object : Callback { override fun onFailure(call: Call, e: IOException) { e.printStackTrace() } override fun onResponse(call: Call, response: Response) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Fri Feb 18 08:52:22 UTC 2022 - 40.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
} @Test fun call() { val call: Call = object : Call { override fun request(): Request = TODO() override fun execute(): Response = TODO() override fun enqueue(responseCallback: Callback) = TODO() override fun cancel() = TODO() override fun isExecuted(): Boolean = TODO() override fun isCanceled(): Boolean = TODO()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 46.5K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
</dependency> ``` * **Fix: improve parallelism of async requests.** OkHttp's Dispatcher had a misconfigured `ExecutorService` that limited the number of worker threads. If you're using `Call.enqueue()` this update should significantly improve request concurrency. * **Fix: Lazily initialize the response cache.** This avoids strict mode warnings when initializing OkHttp on Android‘s main thread.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 26.6K bytes - Viewed (0)