Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 323 for Enqueue (0.09 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top