- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Kistner (0.21 sec)
-
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
server.processNextFrame() client.listener.assertClosing(1000, "Hello!") server.listener.assertClosing(1000, "Hi!") client.webSocket!!.finishReader() server.webSocket!!.finishReader() client.listener.assertClosed(1000, "Hello!") server.listener.assertClosed(1000, "Hi!") taskFaker.runTasks() assertThat(client.closed).isTrue()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
val dispatcher = Dispatcher(executor) val listener = RecordingEventListener() var client = clientTestRule.newClientBuilder() .dns { throw UnknownHostException() } .dispatcher(dispatcher) .eventListenerFactory(clientTestRule.wrap(listener)) .build() @BeforeEach fun setUp() { dispatcher.maxRequests = 20 dispatcher.maxRequestsPerHost = 10 listener.forbidLock(dispatcher) } @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
peer.play() // Play it back. val connection = Http2Connection.Builder(true, TaskRunner.INSTANCE) .socket(peer.openSocket()) .pushObserver(Http2ConnectionTest.IGNORE) .listener(realConnection) .build() connection.start(sendConnectionPreface = false) // verify the peer received the ACK val ackFrame = peer.takeFrame()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
client -> "$okHttpName $peerName" else -> "MockWebServer $peerName" } this.source = source this.sink = sink } fun listener(listener: Listener) = apply { this.listener = listener } fun pushObserver(pushObserver: PushObserver) = apply { this.pushObserver = pushObserver }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
/** Uses [request] to connect a new web socket. */ override fun newWebSocket( request: Request, listener: WebSocketListener, ): WebSocket { val webSocket = RealWebSocket( taskRunner = taskRunner, originalRequest = request, listener = listener, random = Random(), pingIntervalMillis = pingIntervalMillis.toLong(),
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
listener.removeUpToEvent(ConnectionAcquired::class.java) listener.removeUpToEvent(ResponseFailed::class.java) listener.removeUpToEvent(ConnectionReleased::class.java) listener.removeUpToEvent(ConnectionAcquired::class.java) listener.removeUpToEvent(ConnectionReleased::class.java) listener.removeUpToEvent(CallEnd::class.java) } @Test fun recoverWhenRetryOnConnectionFailureIsTrue_HTTP2() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSources.kt
return EventSource.Factory { request, listener -> val actualRequest = if (request.header("Accept") == null) { request.newBuilder().addHeader("Accept", "text/event-stream").build() } else { request } RealEventSource(actualRequest, listener).apply { connect(callFactory) } } } @JvmStatic
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:18:15 GMT 2024 - 1.6K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
private var protocol: Protocol?, private var source: BufferedSource?, private var sink: BufferedSink?, private val pingIntervalMillis: Int, internal val connectionListener: ConnectionListener, ) : Http2Connection.Listener(), Connection, ExchangeCodec.Carrier { private var http2Connection: Http2Connection? = null internal val lock: ReentrantLock = ReentrantLock() // These properties are guarded by [lock]. /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
* [requestBodyOpen], [responseBodyOpen], and [expectMoreExchanges]. * * This will release the connection if it is still held. * * It will also notify the listener that the call completed; either successfully or * unsuccessfully. * * If the call was canceled or timed out, this will wrap [e] in an exception that provides that
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer: MockHttp2Peer, pushObserver: PushObserver = IGNORE, listener: Http2Connection.Listener = Http2Connection.Listener.REFUSE_INCOMING_STREAMS, ): Http2Connection { val connection = Http2Connection.Builder(true, TaskRunner.INSTANCE) .socket(peer.openSocket()) .pushObserver(pushObserver) .listener(listener) .build() connection.start(sendConnectionPreface = false)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0)