- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 47 for promise (0.18 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
flags = FLAG_ACK, ) sink.flush() } } /** * HTTP/2 only. Send a push promise header block. * * A push promise contains all the headers that pertain to a server-initiated request, and a * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent as * a part of the response to `streamId`. The `promisedStreamId` has a priority of one greater than
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
} override fun pushPromise( streamId: Int, associatedStreamId: Int, headerBlock: List<Header>, ) { this.type = Http2.TYPE_PUSH_PROMISE this.streamId = streamId this.associatedStreamId = associatedStreamId this.headerBlock = headerBlock } override fun alternateService( streamId: Int, origin: String,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
weight: Int, exclusive: Boolean, ) /** * HTTP/2 only. Receive a push promise header block. * * A push promise contains all the headers that pertain to a server-initiated request, and a * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent * as a part of the response to `streamId`. *
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt
val result = if (flags < FLAGS.size) FLAGS[flags]!! else BINARY[flags] // Special case types that have overlap flag values. return when { type == TYPE_PUSH_PROMISE && flags and FLAG_END_PUSH_PROMISE != 0 -> { result.replace("HEADERS", "PUSH_PROMISE") // TODO: Avoid allocation. } type == TYPE_DATA && flags and FLAG_COMPRESSED != 0 -> { result.replace("PRIORITY", "COMPRESSED") // TODO: Avoid allocation.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.7K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockResponse.kt
headersDelayAmount = delay headersDelayUnit = unit } fun getHeadersDelay(unit: TimeUnit): Long = unit.convert(headersDelayAmount, headersDelayUnit) fun withPush(promise: PushPromise) = apply { promises.add(promise) } fun withSettings(settings: Settings) = apply { this.settings = settings } fun withWebSocketUpgrade(listener: WebSocketListener) =
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SocketChannelTest.kt
val request = Request.Builder() .url(url) .build() val promise = CompletableFuture<Response>() val call = client.newCall(request) call.enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) { promise.completeExceptionally(e) } override fun onResponse(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/FrameLogTest.kt
assertThat(frameLog(true, 3, 10000, TYPE_CONTINUATION, 0x4)) .isEqualTo("<< 0x00000003 10000 CONTINUATION END_HEADERS") assertThat(frameLog(true, 4, 10000, TYPE_PUSH_PROMISE, 0x4)) .isEqualTo("<< 0x00000004 10000 PUSH_PROMISE END_PUSH_PROMISE") } @Test fun flagOverlapOn0x20() { assertThat(frameLog(true, 3, 10000, TYPE_HEADERS, 0x20)) .isEqualTo("<< 0x00000003 10000 HEADERS PRIORITY")
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
private val writerQueue = taskRunner.newQueue() /** Ensures push promise callbacks events are sent in order per stream. */ private val pushQueue = taskRunner.newQueue() /** Notifies the listener of settings changes. */ private val settingsListenerQueue = taskRunner.newQueue() /** User code to run in response to push promise events. */ private val pushObserver: PushObserver = builder.pushObserver
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
Header(Header.TARGET_PATH, "/"), ) // Write the push promise frame, specifying the associated stream ID. val headerBytes = literalHeaders(pushPromise) writeMedium(frame, (headerBytes.size + 4).toInt()) frame.writeByte(Http2.TYPE_PUSH_PROMISE) frame.writeByte(Http2.FLAG_END_PUSH_PROMISE) frame.writeInt(expectedStreamId and 0x7fffffff)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 28.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FakeProxySelector.kt
class FakeProxySelector : ProxySelector() { val proxies: MutableList<Proxy> = mutableListOf() fun addProxy(proxy: Proxy): FakeProxySelector { proxies.add(proxy) return this } override fun select(uri: URI): List<Proxy> { // Don't handle 'socket' schemes, which the RI's Socket class may request (for SOCKS). return if (uri.scheme == "http" || uri.scheme == "https") proxies else listOf(Proxy.NO_PROXY) }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.3K bytes - Viewed (0)