- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for removeUpToEvent (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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)