Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for CancelCall (0.04 sec)

  1. samples/guide/src/main/java/okhttp3/recipes/kt/CancelCall.kt

     */
    package okhttp3.recipes.kt
    
    import java.io.IOException
    import java.util.concurrent.Executors
    import java.util.concurrent.TimeUnit
    import okhttp3.OkHttpClient
    import okhttp3.Request
    
    class CancelCall {
      private val executor = Executors.newScheduledThreadPool(1)
      private val client = OkHttpClient()
    
      fun run() {
        val request =
          Request.Builder()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  2. samples/guide/src/main/java/okhttp3/recipes/CancelCall.java

    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    import okhttp3.Call;
    import okhttp3.OkHttpClient;
    import okhttp3.Request;
    import okhttp3.Response;
    
    public class CancelCall {
      private final ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
      private final OkHttpClient client = new OkHttpClient();
    
      public void run() throws Exception {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 12 03:31:36 UTC 2019
    - 2.1K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

       * will not be made until any currently-executing task has completed. Tasks that return true will
       * be removed from the execution schedule.
       */
      fun cancelAll() {
        lock.assertNotHeld()
    
        taskRunner.lock.withLock {
          if (cancelAllAndDecide()) {
            taskRunner.kickCoordinator(this)
          }
        }
      }
    
      fun shutdown() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

        }
        return null
      }
    
      /**
       * Cancel all calls currently enqueued or executing. Includes calls executed both
       * [synchronously][Call.execute] and [asynchronously][Call.enqueue].
       */
      fun cancelAll() {
        this.withLock {
          for (call in readyAsyncCalls) {
            call.call.cancel()
          }
          for (call in runningAsyncCalls) {
            call.call.cancel()
          }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Jun 20 14:10:53 UTC 2024
    - 9K bytes
    - Viewed (0)
Back to top