Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 35 for trailers (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockResponse.kt

      @JvmName("-deprecated_getTrailers")
      @Deprecated(
        message = "moved to var",
        replaceWith = ReplaceWith(expression = "trailers"),
        level = DeprecationLevel.ERROR,
      )
      fun getTrailers(): Headers = trailers
    
      fun setTrailers(trailers: Headers) = apply { this.trailers = trailers }
    
      @JvmName("-deprecated_getSocketPolicy")
      @Deprecated(
        message = "moved to var",
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat May 10 11:15:14 GMT 2025
    - 7.1K bytes
    - Click Count (1)
  2. okhttp/src/jvmTest/kotlin/okhttp3/HeadersRequestTest.kt

        val request =
          Request
            .Builder()
            .url("http://square.com/")
            .header("TE", "trailers")
            .build()
        val expected =
          headerEntries(
            ":method",
            "GET",
            ":path",
            "/",
            ":scheme",
            "http",
            "te",
            "trailers",
          )
        assertThat(http2HeadersList(request)).isEqualTo(expected)
      }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 2.5K bytes
    - Click Count (0)
  3. cmd/streaming-v4-unsigned.go

    			req.Trailer.Add(key, "")
    		}
    	} else {
    		req.Trailer = nil
    	}
    	return &s3UnsignedChunkedReader{
    		trailers: req.Trailer,
    		reader:   bufio.NewReader(req.Body),
    		buffer:   make([]byte, 64*1024),
    	}, ErrNone
    }
    
    // Represents the overall state that is required for decoding a
    // AWS Signature V4 chunked reader.
    type s3UnsignedChunkedReader struct {
    	reader   *bufio.Reader
    	trailers http.Header
    
    	buffer []byte
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Apr 03 14:55:52 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  4. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt

      for (pushPromise in pushPromises) {
        result.addPush(pushPromise.wrap())
      }
    
      result.settings(settings)
      result.status(status)
      result.headers(headers)
      result.trailers(trailers)
    
      when (socketPolicy) {
        SocketPolicy.EXPECT_CONTINUE, SocketPolicy.CONTINUE_ALWAYS -> {
          result.add100Continue()
        }
    
        SocketPolicy.UPGRADE_TO_SSL_AT_END -> {
          result.inTunnel()
        }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 4.3K bytes
    - Click Count (1)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/ExchangeCodec.kt

    interface ExchangeCodec {
      /** The connection or CONNECT tunnel that owns this codec. */
      val carrier: Carrier
    
      /** Returns true if the response body and (possibly empty) trailers have been received. */
      val isResponseComplete: Boolean
    
      /** The socket that carries this exchange. */
      val socket: Socket
    
      /** Returns an output stream where the request body can be streamed. */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jul 29 21:11:09 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt

              else -> {
                val responseBody = exchange.openResponseBody(response)
                response
                  .newBuilder()
                  .body(responseBody)
                  .trailers(
                    object : TrailersSource {
                      override fun peek() = exchange.peekTrailers()
    
                      override fun get(): Headers {
                        val source = responseBody.source()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Oct 30 13:46:58 GMT 2025
    - 7.6K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/HeadersReader.kt

      fun readLine(): String {
        val line = source.readUtf8LineStrict(headerLimit)
        headerLimit -= line.length.toLong()
        return line
      }
    
      /** Reads headers or trailers. */
      fun readHeaders(): Headers {
        val result = Headers.Builder()
        while (true) {
          val line = readLine()
          if (line.isEmpty()) break
          result.addLenient(line)
        }
        return result.build()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 1.4K bytes
    - Click Count (0)
  8. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/KotlinSourceModernTest.kt

        var trailers: Headers = mockResponse.trailers
        mockResponse = mockResponse.clearHeaders()
        mockResponse = mockResponse.addHeader("")
        mockResponse = mockResponse.addHeader("", "")
        mockResponse = mockResponse.addHeaderLenient("", Any())
        mockResponse = mockResponse.setHeader("", Any())
        mockResponse.headers = headersOf()
        mockResponse.trailers = headersOf()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 7.3K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt

            // header names must be lowercase.
            val name = headers.name(i).lowercase(Locale.US)
            if (name !in HTTP_2_SKIPPED_REQUEST_HEADERS ||
              name == TE &&
              headers.value(i) == "trailers"
            ) {
              result.add(Header(name, headers.value(i)))
            }
          }
          return result
        }
    
        /** Returns headers for a name value block containing an HTTP/2 response. */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jul 29 21:11:09 GMT 2025
    - 7K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/CookieJar.kt

       *
       * Note that this method may be called a second time for a single HTTP response if the response
       * includes a trailer. For this obscure HTTP feature, [cookies] contains only the trailer's
       * cookies.
       */
      fun saveFromResponse(
        url: HttpUrl,
        cookies: List<Cookie>,
      )
    
      /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 2.4K bytes
    - Click Count (0)
Back to Top