Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for queuedCallsCount (0.06 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/ClientRuleEventListener.kt

        call: Call,
        dispatcher: Dispatcher,
      ) {
        logWithTime("dispatcherQueueStart: queuedCallsCount=${dispatcher.queuedCallsCount()}")
      }
    
      override fun dispatcherQueueEnd(
        call: Call,
        dispatcher: Dispatcher,
      ) {
        logWithTime("dispatcherQueueEnd: queuedCallsCount=${dispatcher.queuedCallsCount()}")
      }
    
      override fun proxySelectStart(
        call: Call,
        url: HttpUrl,
      ) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:03:04 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  2. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/LoggingEventListener.kt

        call: Call,
        dispatcher: Dispatcher,
      ) {
        logWithTime("dispatcherQueueStart: $call queuedCallsCount=${dispatcher.queuedCallsCount()}")
      }
    
      override fun dispatcherQueueEnd(
        call: Call,
        dispatcher: Dispatcher,
      ) {
        logWithTime("dispatcherQueueEnd: $call queuedCallsCount=${dispatcher.queuedCallsCount()}")
      }
    
      override fun proxySelectStart(
        call: Call,
        url: HttpUrl,
      ) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Oct 06 13:40:20 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt

        a1.enqueue(callback)
        a2.enqueue(callback)
        a3.enqueue(callback)
        a4.enqueue(callback)
        a5.enqueue(callback)
        assertThat(dispatcher.runningCallsCount()).isEqualTo(3)
        assertThat(dispatcher.queuedCallsCount()).isEqualTo(2)
        assertThat(dispatcher.runningCalls())
          .containsExactlyInAnyOrder(a1, a2, a3)
        assertThat(dispatcher.queuedCalls())
          .containsExactlyInAnyOrder(a4, a5)
      }
    
      @Test
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt

      /** Returns a snapshot of the calls currently being executed. */
      @Synchronized
      fun runningCalls(): List<Call> = (runningSyncCalls + runningAsyncCalls.map { it.call }).unmodifiable()
    
      @Synchronized
      fun queuedCallsCount(): Int = readyAsyncCalls.size
    
      @Synchronized
      fun runningCallsCount(): Int = runningAsyncCalls.size + runningSyncCalls.size
    
      @JvmName("-deprecated_executorService")
      @Deprecated(
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 14:16:22 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt

        dispatcher.idleCallback = Runnable { ({ TODO() })() }
        val queuedCalls: List<Call> = dispatcher.queuedCalls()
        val runningCalls: List<Call> = dispatcher.runningCalls()
        val queuedCallsCount: Int = dispatcher.queuedCallsCount()
        val runningCallsCount: Int = dispatcher.runningCallsCount()
        dispatcher.cancelAll()
      }
    
      @Test
      fun dispatcherFromMockWebServer() {
        val dispatcher =
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 47K bytes
    - Viewed (0)
  6. okhttp/api/jvm/okhttp.api

    	public final fun getIdleCallback ()Ljava/lang/Runnable;
    	public final fun getMaxRequests ()I
    	public final fun getMaxRequestsPerHost ()I
    	public final fun queuedCalls ()Ljava/util/List;
    	public final fun queuedCallsCount ()I
    	public final fun runningCalls ()Ljava/util/List;
    	public final fun runningCallsCount ()I
    	public final fun setIdleCallback (Ljava/lang/Runnable;)V
    	public final fun setMaxRequests (I)V
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 70.2K bytes
    - Viewed (0)
  7. okhttp/api/android/okhttp.api

    	public final fun getIdleCallback ()Ljava/lang/Runnable;
    	public final fun getMaxRequests ()I
    	public final fun getMaxRequestsPerHost ()I
    	public final fun queuedCalls ()Ljava/util/List;
    	public final fun queuedCallsCount ()I
    	public final fun runningCalls ()Ljava/util/List;
    	public final fun runningCallsCount ()I
    	public final fun setIdleCallback (Ljava/lang/Runnable;)V
    	public final fun setMaxRequests (I)V
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 70.3K bytes
    - Viewed (0)
Back to top