Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 382 for Until (0.02 sec)

  1. docs/features/connections.md

     * When making TLS connections with multiple [connection specs](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-connection-spec/), these are attempted in sequence until the TLS handshake succeeds.
    
    ### [Connections](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-connection/)
    
    When you request a URL with OkHttp, here's what it does:
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Feb 21 03:33:59 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

            }
            requestMethod = source.readUtf8LineStrict()
            val varyHeadersBuilder = Headers.Builder()
            val varyRequestHeaderLineCount = readInt(source)
            for (i in 0 until varyRequestHeaderLineCount) {
              varyHeadersBuilder.addLenient(source.readUtf8LineStrict())
            }
            varyHeaders = varyHeadersBuilder.build()
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 26.9K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt

        var wildcardMatch: String? = null
        if (domainLabelsUtf8Bytes.size > 1) {
          val labelsWithWildcard = domainLabelsUtf8Bytes.clone()
          for (labelIndex in 0 until labelsWithWildcard.size - 1) {
            labelsWithWildcard[labelIndex] = WILDCARD_LABEL
            val rule = publicSuffixList.bytes.binarySearch(labelsWithWildcard, labelIndex)
            if (rule != null) {
    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. guava-testlib/src/com/google/common/testing/GcFinalization.java

        // TODO(user): Consider scaling by number of mutator threads,
        // e.g. using Thread#activeCount()
        return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L));
      }
    
      /**
       * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector
       * as necessary to try to ensure that this will happen.
       *
       * @throws RuntimeException if timed out or interrupted while waiting
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/FluentIterable.java

      /**
       * Returns a fluent iterable that combines two iterables. The returned iterable has an iterator
       * that traverses the elements in {@code a}, followed by the elements in {@code b}. The source
       * iterators are not polled until necessary.
       *
       * <p>The returned iterable's iterator supports {@code remove()} when the corresponding input
       * iterator supports it.
       *
       * <p><b>{@code Stream} equivalent:</b> {@link Stream#concat}.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 35.3K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/FluentIterable.java

      /**
       * Returns a fluent iterable that combines two iterables. The returned iterable has an iterator
       * that traverses the elements in {@code a}, followed by the elements in {@code b}. The source
       * iterators are not polled until necessary.
       *
       * <p>The returned iterable's iterator supports {@code remove()} when the corresponding input
       * iterator supports it.
       *
       * <p><b>{@code Stream} equivalent:</b> {@link Stream#concat}.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/MockHttp2Peer.kt

        return writer
      }
    
      /**
       * Shortens the last frame from its original length to `length`. This will cause the peer to
       * close the socket as soon as this frame has been written; otherwise the peer stays open until
       * explicitly closed.
       */
      fun truncateLastFrame(length: Int): Http2Writer {
        val lastFrame = outFrames.removeAt(outFrames.size - 1)
        require(length < bytesOut.size - lastFrame.start)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  8. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt

                if (headers["Content-Length"] == null) {
                  logger.log("Content-Length: ${requestBody.contentLength()}")
                }
              }
            }
    
            for (i in 0 until headers.size) {
              logHeader(headers, i)
            }
    
            if (!logBody || requestBody == null) {
              logger.log("--> END ${request.method}")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Aug 21 14:27:04 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

           */
          @Override
          protected boolean tryReleaseShared(int finalState) {
            setState(finalState);
            return true;
          }
    
          /**
           * Blocks until the task is complete or the timeout expires. Throws a {@link TimeoutException}
           * if the timer expires, otherwise behaves like {@link #get()}.
           */
          V get(long nanos)
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jan 30 16:59:10 UTC 2025
    - 13.7K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/it/CrawlTestBase.java

            fail("could not start job.");
        }
    
        protected static void waitJob(final String namePrefix) {
            Boolean isRunning = false;
            int count = 0;
    
            while (count < 300 && !isRunning) { // Wait until the crawler starts
                ThreadUtil.sleep(500);
                count++;
                final Map<String, Object> scheduler = getSchedulerItem(namePrefix);
                assertTrue(scheduler.containsKey("running"));
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 10K bytes
    - Viewed (0)
Back to top