- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for Leer (0.18 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
fun writeTimeout(): Timeout = writeTimeout /** Returns a source that reads data from the peer. */ fun getSource(): Source = source /** * Returns a sink that can be used to write data to the peer. * * @throws IllegalStateException if this stream was initiated by the peer and a [writeHeaders] has * not yet been sent. */ fun getSink(): Sink { this.withLock {
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) -
okhttp/src/main/kotlin/okhttp3/internal/http2/ConnectionShutdownException.kt
* limitations under the License. */ package okhttp3.internal.http2 import java.io.IOException /** * Thrown when an HTTP/2 connection is shutdown (either explicitly or if the peer has sent a GOAWAY * frame) and an attempt is made to use the connection. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 875 bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSourceListener.kt
* limitations under the License. */ package okhttp3.sse import okhttp3.Response abstract class EventSourceListener { /** * Invoked when an event source has been accepted by the remote peer and may begin transmitting * events. */ open fun onOpen( eventSource: EventSource, response: Response, ) { } /** * TODO description. */ open fun onEvent(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (1) -
samples/guide/src/main/java/okhttp3/recipes/CheckHandshake.java
for (Certificate certificate : chain.connection().handshake().peerCertificates()) { String pin = CertificatePinner.pin(certificate); if (denylist.contains(pin)) { throw new IOException("Denylisted peer certificate: " + pin); } } return chain.proceed(chain.request()); } }; private final OkHttpClient client = new OkHttpClient.Builder()
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 2.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FakeSSLSession.kt
} @Suppress("UNCHECKED_CAST") @Throws(SSLPeerUnverifiedException::class) override fun getPeerCertificates(): Array<Certificate> { return if (certificates.isEmpty()) { throw SSLPeerUnverifiedException("peer not authenticated") } else { certificates as Array<Certificate> } } @Throws( SSLPeerUnverifiedException::class, ) override fun getPeerCertificateChain(): Array<X509Certificate> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt
object Http2 { @JvmField val CONNECTION_PREFACE = "PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n".encodeUtf8() /** The initial max frame size, applied independently writing to, or reading from the peer. */ const val INITIAL_MAX_FRAME_SIZE = 0x4000 // 16384 const val TYPE_DATA = 0x0 const val TYPE_HEADERS = 0x1 const val TYPE_PRIORITY = 0x2 const val TYPE_RST_STREAM = 0x3 const val TYPE_SETTINGS = 0x4
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
outFrames.add(OutFrame(frameCount++, bytesOut.size, false)) return writer } /** * Shortens the last frame from its original length to `length`. This will cause the peer to * close the socket as soon as this frame has been written; otherwise the peer stays open until * explicitly closed. */ fun truncateLastFrame(length: Int): Http2Writer { val lastFrame = outFrames.removeAt(outFrames.size - 1)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketWriterTest.kt
if (context.executionException.isPresent) return@AfterEachCallback assertThat(data.readByteString().hex(), "Data not empty") .isEqualTo("") } // Mutually exclusive. Use the one corresponding to the peer whose behavior you wish to test. private val serverWriter = WebSocketWriter( isClient = false, sink = data, random = random, perMessageDeflate = false, noContextTakeover = false,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.3K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
server.useHttps(handshakeCertificates.sslSocketFactory(), false) ``` Get these strings with `HeldCertificate.certificatePem()` and `privateKeyPkcs8Pem()`. * Fix: Handshake now returns peer certificates in canonical order: each certificate is signed by the certificate that follows and the last certificate is signed by a trusted root.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
shouldntImpactConnection[Settings.INITIAL_WINDOW_SIZE] = 3368 peer.sendFrame().settings(initial) peer.acceptFrame() // ACK peer.sendFrame().settings(shouldntImpactConnection) peer.acceptFrame() // ACK 2 peer.acceptFrame() // HEADERS peer.play() val connection = connect(peer) // Verify the peer received the second ACK. val ackFrame = peer.takeFrame()
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)