Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 79 for exhaust (0.03 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketReaderTest.kt

        data.write("880203ee".decodeHex()) // Close with code 1006
        for (i in 1015..2999) {
          data.write(("8802" + format("%04X", i)).decodeHex()) // Close with code 'i'
        }
        var count = 0
        while (!data.exhausted()) {
          assertFailsWith<ProtocolException> {
            clientReader.processNextFrame()
          }.also { expected ->
            assertThat(expected.message!!)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

      private val Request.isChunked: Boolean
        get() = "chunked".equals(header("Transfer-Encoding"), ignoreCase = true)
    
      /**
       * Trailers received when the response body became exhausted.
       *
       * If the response body was successfully read until the end, this is the headers that followed,
       * or empty headers if there were none that followed.
       *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 17.5K bytes
    - Viewed (7)
  3. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

         * on the socket.
         */
        @Throws(IOException::class, InterruptedException::class)
        private fun processOneRequest(socket: MockWebServerSocket): Boolean {
          if (socket.source.exhausted()) {
            return false // No more requests on this socket.
          }
    
          val request =
            readRequest(
              socket = socket,
              connectionIndex = connectionIndex,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 20:36:00 UTC 2025
    - 40.3K bytes
    - Viewed (0)
  4. mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt

        ): Builder =
          apply {
            removeHeader("Content-Length")
            headers_.add("Transfer-encoding: chunked")
    
            val bytesOut = Buffer()
            while (!body.exhausted()) {
              val chunkSize = minOf(body.size, maxChunkSize.toLong())
              bytesOut.writeHexadecimalUnsignedLong(chunkSize)
              bytesOut.writeUtf8("\r\n")
              bytesOut.write(body, chunkSize)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt

           * propagate the never indexed flag of a header.
           */
          @Throws(IOException::class)
          fun readHeaders() {
            while (!source.exhausted()) {
              val b = source.readByte() and 0xff
              when {
                b == 0x80 -> {
                  // 10000000
                  throw IOException("index == 0")
                }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

       *
       * Will only be invoked for requests having a response body e.g. won't be invoked for a web socket
       * upgrade.
       *
       * If the response body is closed before the response body is exhausted, this is invoked at the
       * time it is closed. In such calls [byteCount] is the number of bytes returned to the
       * application. This may be smaller than the resource's byte count if were read to completion.
       *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        limiter.acquire(1); // R0.00, from capacity
        limiter.acquire(3); // R0.00, from capacity
        limiter.acquire(1); // R0.00, concluding a burst of 5 permits
    
        limiter.acquire(); // R0.20, capacity exhausted
        assertEvents(
            "U1.00", "U1.00", "R0.00", "R0.00", "R0.00", "R0.00", // first request and burst
            "R0.20");
      }
    
      public void testCreateWarmupParameterValidation() {
        RateLimiter unused;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        limiter.acquire(1); // R0.00, from capacity
        limiter.acquire(3); // R0.00, from capacity
        limiter.acquire(1); // R0.00, concluding a burst of 5 permits
    
        limiter.acquire(); // R0.20, capacity exhausted
        assertEvents(
            "U1.00", "U1.00", "R0.00", "R0.00", "R0.00", "R0.00", // first request and burst
            "R0.20");
      }
    
      public void testCreateWarmupParameterValidation() {
        RateLimiter unused;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

                  cancel()
                }
              }
            } else if (messageOrClose == null) {
              return false // The queue is exhausted.
            }
          }
        }
    
        try {
          if (pong != null) {
            writer!!.writePong(pong)
          } else if (messageOrClose is Message) {
            val message = messageOrClose
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

              val peerCertificates = readCertificateList(source)
              val localCertificates = readCertificateList(source)
              val tlsVersion =
                if (!source.exhausted()) {
                  TlsVersion.forJavaName(source.readUtf8LineStrict())
                } else {
                  TlsVersion.SSL_3_0
                }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 26.9K bytes
    - Viewed (0)
Back to top