- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for Kersting (0.29 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
} catch (e: IOException) { failConnection(e) } } /** For testing: sends a ping and waits for a pong. */ @Throws(InterruptedException::class) fun writePingAndAwaitPong() { writePing() awaitPong() } /** For testing: sends a ping to be awaited with [awaitPong]. */ @Throws(InterruptedException::class) fun writePing() { this.withLock {
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/internal/ws/RealWebSocket.kt
reader!!.processNextFrame() } } catch (e: Exception) { failWebSocket(e = e) } finally { finishReader() } } /** * For testing: receive a single frame and return true if there are more frames to read. Invoked * only by the reader thread. */ @Throws(IOException::class) fun processNextFrame(): Boolean { return try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/OkHttpClientTest.kt
import kotlin.test.assertFailsWith import mockwebserver3.MockResponse import mockwebserver3.MockWebServer import okhttp3.internal.platform.Platform.Companion.get import okhttp3.internal.proxy.NullProxySelector import okhttp3.testing.PlatformRule import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.Assertions.assertEquals import org.junit.jupiter.api.Assertions.assertNotSame import org.junit.jupiter.api.Assertions.assertSame
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 13.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
// RST this stream to prevent additional data from being sent. This is safe because the input // stream is closed (we won't use any further bytes) and the output stream is either finished // or closed (so RSTing both streams doesn't cause harm). ******@****.***(ErrorCode.CANCEL, null) } else if (!open) { connection.removeStream(id) } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
val socket = sslSocketFactory.createSocket( raw, raw.inetAddress.hostAddress, raw.port, true, ) as SSLSocket try { socket.startHandshake() // we're testing a handshake failure throw AssertionError() } catch (expected: IOException) { } socket.close() } @Throws(InterruptedException::class) private fun dispatchBookkeepingRequest(
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) -
okhttp/src/test/java/okhttp3/CacheTest.kt
import okhttp3.internal.addHeaderLenient import okhttp3.internal.cacheGet import okhttp3.internal.platform.Platform.Companion.get import okhttp3.java.net.cookiejar.JavaNetCookieJar import okhttp3.testing.PlatformRule import okio.Buffer import okio.FileSystem import okio.ForwardingFileSystem import okio.GzipSink import okio.Path import okio.Path.Companion.toPath import okio.buffer
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 108.6K bytes - Viewed (0) -
container-tests/src/test/java/okhttp3/containers/BasicLoomTest.kt
import okhttp3.OkHttpClient import okhttp3.Request import okhttp3.containers.BasicMockServerTest.Companion.MOCKSERVER_IMAGE import okhttp3.containers.BasicMockServerTest.Companion.trustMockServer import okhttp3.testing.PlatformRule import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Test import org.junit.jupiter.api.extension.RegisterExtension
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 11:15:46 GMT 2024 - 3.7K bytes - Viewed (0)