- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for Kistner (0.17 sec)
-
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/DuplexTest.kt
var clientTestRule = OkHttpClientTestRule() private lateinit var server: MockWebServer private var listener = RecordingEventListener() private val handshakeCertificates = platform.localhostHandshakeCertificates() private var client = clientTestRule.newClientBuilder() .eventListenerFactory(clientTestRule.wrap(listener)) .build() private val executorService = Executors.newScheduledThreadPool(1) @BeforeEach
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 23.9K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
val http2SocketHandler = Http2SocketHandler(socket, protocol) val connection = Http2Connection.Builder(false, taskRunner) .socket(socket) .listener(http2SocketHandler) .build() connection.start() openConnections.add(connection) openClientSockets.remove(socket) return } else if (protocol !== Protocol.HTTP_1_1) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
* * Steps to run in your own code * * 1. In your main method `WireSharkListenerFactory.register()` * 2. Create Listener factory `val eventListenerFactory = WireSharkListenerFactory( logFile = File("/tmp/key.log"), tlsVersions = tlsVersions, launch = launch)` * 3. Register with `client.eventListenerFactory(eventListenerFactory)`
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/EventListener.kt
* limitations under the License. */ package okhttp3 import java.io.IOException import java.net.InetAddress import java.net.InetSocketAddress import java.net.Proxy /** * Listener for metrics events. Extend this class to monitor the quantity, size, and duration of * your application's HTTP calls. * * All start/connect/acquire events will eventually receive a matching end/release event, either
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
} responseBody.close() assertEquals(if (connectionType == H2) 1 else 0, client.connectionPool.connectionCount()) cancelLatch.await() val events = listener.eventSequence.filter { isConnectionEvent(it) }.map { it.name } listener.clearAllEvents() assertThat(events).startsWith("CallStart", "ConnectStart", "ConnectEnd", "ConnectionAcquired") if (cancelMode == CANCEL) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt
* first DNS result for the first time. */ @Test fun prefersExistingCompatible() { server.enqueue(MockResponse()) server.enqueue(MockResponse()) val connectCount = AtomicInteger() val listener: EventListener = object : EventListener() { override fun connectStart( call: Call, inetSocketAddress: InetSocketAddress, proxy: Proxy, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 18.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/tls/ClientAuthTest.kt
.validityInterval(1, 2) .build() var client = buildClient(clientCert, clientIntermediateCa.certificate) val listener = RecordingEventListener() client = client.newBuilder() .eventListener(listener) .build() val socketFactory = buildServerSslSocketFactory() server.useHttps(socketFactory) server.requireClientAuth()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 12.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
* This will overwrite any previously set status, body, or streamHandler. */ fun webSocketUpgrade(listener: WebSocketListener) = apply { status = "HTTP/1.1 101 Switching Protocols" setHeader("Connection", "Upgrade") setHeader("Upgrade", "websocket") webSocketListener = listener } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 13.3K bytes - Viewed (1)