Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 20 for pushPromise (0.2 sec)

  1. mockwebserver-deprecated/api/mockwebserver.api

    	public fun toString ()Ljava/lang/String;
    	public final fun trailers (Lokhttp3/Headers;)V
    	public final fun withPush (Lokhttp3/mockwebserver/PushPromise;)Lokhttp3/mockwebserver/MockResponse;
    	public final fun withSettings (Lokhttp3/internal/http2/Settings;)Lokhttp3/mockwebserver/MockResponse;
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jul 22 12:28:51 GMT 2023
    - 10.2K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/http2/BaseTestHandler.kt

      ) {
        fail("")
      }
    
      override fun priority(
        streamId: Int,
        streamDependency: Int,
        weight: Int,
        exclusive: Boolean,
      ) {
        fail("")
      }
    
      override fun pushPromise(
        streamId: Int,
        associatedStreamId: Int,
        headerBlock: List<Header>,
      ) {
        fail("")
      }
    
      override fun alternateService(
        streamId: Int,
        origin: String,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2K bytes
    - Viewed (0)
  3. mockwebserver/api/mockwebserver3.api

    	public final fun addInformationalResponse (Lmockwebserver3/MockResponse;)Lmockwebserver3/MockResponse$Builder;
    	public final fun addPush (Lmockwebserver3/PushPromise;)Lmockwebserver3/MockResponse$Builder;
    	public final fun body (Ljava/lang/String;)Lmockwebserver3/MockResponse$Builder;
    	public final fun body (Lmockwebserver3/MockResponseBody;)Lmockwebserver3/MockResponse$Builder;
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 03 21:59:45 GMT 2023
    - 12.7K bytes
    - Viewed (0)
  4. 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
    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)
  5. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

      ) {
        setUp(protocol, mockWebServer)
        val pushPromise =
          PushPromise(
            "GET",
            "/foo/bar",
            headersOf("foo", "bar"),
            MockResponse(body = "bar"),
          )
        server.enqueue(
          MockResponse.Builder()
            .body("ABCDE")
            .addPush(pushPromise)
            .build(),
        )
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

        val headerBlockLength = lengthWithoutPadding(length - 4, flags, padding) // - 4 for readInt().
        val headerBlock = readHeaderBlock(headerBlockLength, padding, flags, streamId)
        handler.pushPromise(streamId, promisedStreamId, headerBlock)
      }
    
      @Throws(IOException::class)
      private fun readPing(
        handler: Handler,
        length: Int,
        flags: Int,
        streamId: Int,
      ) {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 19.9K bytes
    - Viewed (0)
  7. 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)
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  8. docs/changelogs/upgrading_to_okhttp_4.md

       networkInterceptors, pingIntervalMillis, protocols, proxy, proxyAuthenticator, proxySelector,
       readTimeoutMillis, retryOnConnectionFailure, socketFactory, sslSocketFactory, writeTimeoutMillis
     * **PushPromise**: headers, method, path, response
     * **Request**: body, cacheControl, headers, method, url
     * **Response**: body, cacheControl, cacheResponse, code, handshake, headers, message,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Feb 06 16:58:16 GMT 2022
    - 10.9K bytes
    - Viewed (0)
  9. 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)
    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)
  10. 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)
    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)
Back to top