Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for removeUpToEvent (0.66 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

          )
        val response = call.execute()
        assertThat(response.code).isEqualTo(200)
        response.body.close()
        eventRecorder.removeUpToEvent<DnsStart>()
        eventRecorder.removeUpToEvent<DnsEnd>()
        eventRecorder.removeUpToEvent<DnsStart>()
        eventRecorder.removeUpToEvent<DnsEnd>()
      }
    
      @Test
      fun failedDnsLookup() {
        client =
          client
            .newBuilder()
            .dns(FakeDns())
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 70.5K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt

        val dispatcherQueueStartC1 = eventRecorder.removeUpToEvent<DispatcherQueueStart>()
        assertThat(dispatcherQueueStartC1.call.request().url).isEqualTo("http://c/1".toHttpUrl())
        val dispatcherQueueStartA2 = eventRecorder.removeUpToEvent<DispatcherQueueStart>()
        assertThat(dispatcherQueueStartA2.call.request().url).isEqualTo("http://a/2".toHttpUrl())
        val dispatcherQueueStartB2 = eventRecorder.removeUpToEvent<DispatcherQueueStart>()
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionListenerTest.kt

        assertThat(response.code).isEqualTo(200)
        response.body.close()
        listener.removeUpToEvent(ConnectionEvent.ConnectEnd::class.java)
        listener.removeUpToEvent(ConnectionEvent.ConnectionReleased::class.java)
        listener.removeUpToEvent(ConnectionEvent.ConnectionAcquired::class.java)
        listener.removeUpToEvent(ConnectionEvent.ConnectionReleased::class.java)
      }
    
      @Test
      @Throws(IOException::class)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 18:33:48 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/EventRecorder.kt

            }
          }
        } catch (e: NoSuchElementException) {
          throw AssertionError("full event sequence: $fullEventSequence", e)
        }
      }
    
      inline fun <reified T : CallEvent> removeUpToEvent(): T = removeUpToEvent(T::class.java)
    
      inline fun <reified T : CallEvent> findEvent(): T = eventSequence.first { it is T } as T
    
      /**
       * Remove and return the next event from the recorded sequence.
       *
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  5. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

        forbiddenLocks.add(lock)
      }
    
      /**
       * Removes recorded events up to (and including) an event is found whose class equals [eventClass]
       * and returns it.
       */
      fun <T : ConnectionEvent> removeUpToEvent(eventClass: Class<T>): T {
        val fullEventSequence = eventSequence.toList()
        try {
          while (true) {
            val event = takeEvent()
            if (eventClass.isInstance(event)) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        eventRecorder.removeUpToEvent(CallEnd::class.java)
    
        // The ResponseFailed event is not necessarily fatal!
        eventRecorder.removeUpToEvent(ConnectionAcquired::class.java)
        eventRecorder.removeUpToEvent(ResponseFailed::class.java)
        eventRecorder.removeUpToEvent(ConnectionReleased::class.java)
        eventRecorder.removeUpToEvent(ConnectionAcquired::class.java)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 147.4K bytes
    - Viewed (0)
Back to top