- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for pushPromises (0.17 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 37.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
protocol = Protocol.get("") } @Test fun pushPromise() { val pushPromise: PushPromise = PushPromise("", "", headersOf(), MockResponse()) val method: String = pushPromise.method val path: String = pushPromise.path val headers: Headers = pushPromise.headers val response: MockResponse = pushPromise.response } @Test fun queueDispatcher() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 46.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
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/internal/http2/MockHttp2Peer.kt
override fun priority( streamId: Int, streamDependency: Int, weight: Int, exclusive: Boolean, ) { throw UnsupportedOperationException() } override fun pushPromise( streamId: Int, associatedStreamId: Int, headerBlock: List<Header>, ) { this.type = Http2.TYPE_PUSH_PROMISE this.streamId = streamId
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
* @param promisedStreamId server-initiated stream ID. Must be an even number. * @param requestHeaders minimally includes `:method`, `:scheme`, `:authority`, and `:path`. */ @Throws(IOException::class) fun pushPromise( streamId: Int, promisedStreamId: Int, requestHeaders: List<Header>, ) { this.withLock { if (closed) throw IOException("closed") hpackWriter.writeHeaders(requestHeaders)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
writer.headers(outFinished, streamId, requestHeaders) } else { require(!client) { "client streams shouldn't have associated stream IDs" } // HTTP/2 has a PUSH_PROMISE frame. writer.pushPromise(associatedStreamId, streamId, requestHeaders) } } if (flushHeaders) { writer.flush() } return stream } @Throws(IOException::class)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
@Test fun doublePushPromise() { // Write the mocking script. peer.sendFrame().settings(Settings()) peer.acceptFrame() // ACK peer.sendFrame().pushPromise(3, 2, headerEntries("a", "android")) peer.acceptFrame() // SYN_REPLY peer.sendFrame().pushPromise(3, 2, headerEntries("b", "banana")) peer.acceptFrame() // RST_STREAM peer.play() // Play it back. val connection = connect(peer)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
src/net/http/h2_bundle.go
// // For simplicity, the server code merges "reserved (local)" into // "half-closed (remote)". This is one less state transition to track. // The only downside is that we send PUSH_PROMISEs slightly less // liberally than allowable. More discussion here: // https://lists.w3.org/Archives/Public/ietf-http-wg/2016JulSep/0599.html // // "reserved (remote)" is omitted since the client code does not
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0)