client.newCall(newRequest("http://b/2")).enqueue(callback)
    executor.assertJobs("http://a/1", "http://a/2", "http://b/1")

    val dispatcherQueueStart = eventRecorder.removeUpToEvent<DispatcherQueueStart>()
    assertThat(dispatcherQueueStart.call.request().url).isEqualTo("http://b/2".toHttpUrl())
    assertThat(eventRecorder.eventSequence).none { it.isInstanceOf<DispatcherQueueEnd>() }
  }

  @Test

   * OkHttp performs concurrently.
   */
  open fun dispatcherQueueStart(
    call: Call,
    dispatcher: Dispatcher,
  ) {
  }

  /**
   * Invoked when [call] will be executed immediately.
   *
   * This method is invoked after [dispatcherQueueStart].
   */
  open fun dispatcherQueueEnd(
    call: Call,
    dispatcher: Dispatcher,
  ) {
  }

  /**

        call.failRejected()
      } else {
        call.executeOn(executorService)
      }
    }

    if (callDispatcherQueueStart && enqueuedCall != null) {
      enqueuedCall.call.eventListener.dispatcherQueueStart(enqueuedCall.call, this)
    }

    effects.idleCallbackToRun?.run()
  }

  /** Used by [Call.execute] to signal it is in-flight. */
  @Synchronized

    use it to compose a cache URL from the query body.

 *  New: Publish events when calls must wait to execute. `EventListener.dispatcherQueueStart()`
    is invoked when a call starts waiting, and `dispatcherQueueEnd()` is invoked when it's done.

 *  New: `Request.toCurl()` returns a copy-pasteable [curl] command consistent with Chrome’s and