- Sort Score
- Result 10 results
- Languages All
Results 31 - 33 of 33 for eventListener (0.16 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
server.enqueue( MockResponse(body = "XXX"), ) val connections: MutableList<RealConnection?> = ArrayList() val localClient = client.newBuilder().eventListener( object : EventListener() { override fun connectionAcquired( call: Call, connection: Connection, ) { connections.add(connection as RealConnection)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
throw AssertionError() } super.responseHeadersEnd(call, response) } } client = client.newBuilder() .eventListener(listener) .build() val body = MockStreamHandler() .sendResponse("/a has moved!\n", duplexResponseSent) .requestIOException() .exhaustResponse() server.enqueue(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 23.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
import okio.IOException import org.junit.jupiter.api.Assertions open class RecordingConnectionListener( /** * An override to ignore the normal order that is enforced. * EventListeners added by Interceptors will not see all events. */ private val enforceOrder: Boolean = true, ) : ConnectionListener() { val eventSequence: Deque<ConnectionEvent> = ConcurrentLinkedDeque()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.6K bytes - Viewed (0)