Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 79 for exhaust (0.03 sec)

  1. src/test/java/jcifs/smb/ShareEnumIteratorTest.java

            // End of iteration behavior
            assertFalse(it.hasNext(), "No more elements expected");
            assertNull(it.next(), "next() returns null when exhausted in this implementation");
        }
    
        @Test
        @DisplayName("With filter: only accepted entries are returned and filter is invoked per entry")
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt

        }
    
        /**
         * Returns a value in [0..maxByteCount] with the number of bytes that can be read from [source]
         * in the current part. If this returns 0 the current part is exhausted; otherwise it has at
         * least one byte left to read.
         */
        private fun currentPartBytesRemaining(maxByteCount: Long): Long {
          val toIndex = minOf(source.buffer.size, maxByteCount) + 1L
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 02:11:14 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt

              currentLabelByteIndex++
              if (publicSuffixByteIndex == publicSuffixLength) break
    
              if (labels[currentLabelIndex].size == currentLabelByteIndex) {
                // We've exhausted our current label. Either there are more labels to compare, in which
                // case we expect a dot as the next character. Otherwise, we've checked all our labels.
                if (currentLabelIndex == labels.size - 1) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 28 07:33:49 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt

              maskCursor.seek(messageFrameBuffer.size - frameLength)
              toggleMask(maskCursor, maskKey!!)
              maskCursor.close()
            }
          }
    
          if (isFinalFrame) break // We are exhausted and have no continuations.
    
          readUntilNonControlFrame()
          if (opcode != OPCODE_CONTINUATION) {
            throw ProtocolException("Expected continuation opcode. Got: ${opcode.toHexString()}")
          }
        }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 22:04:11 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  5. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

        try {
          while (currentTask != self) {
            taskRunner.wait()
          }
        } finally {
          serialTaskQueue.remove(yieldCompleteTask)
        }
    
        // If we're yielding until we're exhausted and a task run, keep going until a task doesn't run.
        if (strategy == ResumePriority.AfterOtherTasks && otherTasksStarted) {
          return yieldUntil(strategy, condition)
        }
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  6. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/CertificateAdapters.kt

          override fun fromDer(reader: DerReader): Long {
            val peekHeader =
              reader.peekHeader()
                ?: throw ProtocolException("expected time but was exhausted at $reader")
    
            return when {
              peekHeader.tagClass == Adapters.UTC_TIME.tagClass &&
                peekHeader.tag == Adapters.UTC_TIME.tag -> {
                Adapters.UTC_TIME.fromDer(reader)
              }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 13.6K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilCommon.kt

    internal inline fun ignoreIoExceptions(block: () -> Unit) {
      try {
        block()
      } catch (_: IOException) {
      }
    }
    
    internal fun Buffer.skipAll(b: Byte): Int {
      var count = 0
      while (!exhausted() && this[0] == b) {
        count++
        readByte()
      }
      return count
    }
    
    /**
     * Returns the index of the next non-whitespace character in this. Result is undefined if input
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

            )
          routeSelector = newRouteSelector
        }
    
        // List available IP addresses for the current proxy. This may block in Dns.lookup().
        if (!newRouteSelector.hasNext()) throw IOException("exhausted all routes")
        val newRouteSelection = newRouteSelector.next()
        routeSelection = newRouteSelection
    
        if (isCanceled()) throw IOException("Canceled")
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 12K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-HostnamesCommon.kt

      return result
    }
    
    internal fun idnToAscii(host: String): String? {
      val bufferA = Buffer().writeUtf8(host)
      val bufferB = Buffer()
    
      // 1. Map, from bufferA to bufferB.
      while (!bufferA.exhausted()) {
        val codePoint = bufferA.readUtf8CodePoint()
        if (!IDNA_MAPPING_TABLE.map(codePoint, bufferB)) return null
      }
    
      // 2. Normalize, from bufferB to bufferA.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 11.2K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt

        )
    
        val call = client.newCall(Request(server.url("/")))
        call.execute().use { response ->
          assertThat(response.trailers()).isEqualTo(headersOf("t1", "v2"))
          assertThat(response.body.source().exhausted()).isTrue()
        }
      }
    
      @Test
      @Disabled
      fun trailersAndCacheHttp1() {
        trailersAndCache(Protocol.HTTP_1_1)
      }
    
      @Test
      @Disabled
      fun trailersAndCacheHttp2() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 18K bytes
    - Viewed (0)
Back to top