Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 566 for Until (0.03 seconds)

  1. guava-testlib/src/com/google/common/collect/testing/testers/ListSubListTester.java

       * Returns the {@link Method} instance for {@link #testSubList_originalListSetAffectsSubList()} so
       * that tests of {@link CopyOnWriteArrayList} can suppress them with {@code
       * FeatureSpecificTestSuiteBuilder.suppressing()} until <a
       * href="https://bugs.openjdk.org/browse/JDK-6570631">JDK-6570631</a> is fixed.
       */
      @J2ktIncompatible
      @GwtIncompatible // reflection
      public static Method getSubListOriginalListSetAffectsSubListMethod() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt

       * callback has returned. Synchronous calls become idle once [execute()][Call.execute] returns.
       * This means that if you are doing synchronous calls the network layer will not truly be idle
       * until every returned [Response] has been closed.
       */
      @get:Synchronized
      @set:Synchronized
      var idleCallback: Runnable? = null
    
      private var executorServiceOrNull: ExecutorService? = null
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Oct 07 14:16:22 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  3. okhttp-tls/src/main/kotlin/okhttp3/tls/Certificates.kt

        encodeBase64Lines(encoded.toByteString())
        append("-----END CERTIFICATE-----\n")
      }
    
    internal fun StringBuilder.encodeBase64Lines(data: ByteString) {
      val base64 = data.base64()
      for (i in 0 until base64.length step 64) {
        append(base64, i, minOf(i + 64, base64.length)).append('\n')
      }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 2.8K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        ListenableFuture<Boolean> future2 =
            serializer.submit(blockingCallable::isRunning, directExecutor());
    
        // Wait for the first task to be started in the background. It will block until we explicitly
        // stop it.
        blockingCallable.waitForStart();
    
        // Give the second task a chance to (incorrectly) start up while the first task is running.
        assertThat(future2.isDone()).isFalse();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 13.6K bytes
    - Click Count (0)
  5. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/ModelSource2.java

     * repositories.
     * <p>
     * ModelSource2 instances are cached in {@link ModelBuildingRequest#getModelCache()}. Implementations must guarantee
     * that the connection to the backing store remains active until request's {@link ModelCache} is discarded or flushed.
     *
     * @deprecated use {@code org.apache.maven.api.services.ModelBuilder} instead
     */
    @Deprecated(since = "4.0.0")
    public interface ModelSource2 extends ModelSource {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  6. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/InsecureExtendedTrustManager.kt

    /**
     * This extends [X509ExtendedTrustManager] to disable verification for a set of hosts.
     *
     * Note that the superclass [X509ExtendedTrustManager] isn't available on Android until version 7
     * (API level 24).
     */
    @IgnoreJRERequirement
    internal class InsecureExtendedTrustManager(
      private val delegate: X509ExtendedTrustManager,
      private val insecureHosts: List<String>,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  7. samples/guide/src/main/java/okhttp3/recipes/kt/PostStreaming.kt

              for (i in 2..997) {
                sink.writeUtf8(String.format(" * $i = ${factor(i)}\n"))
              }
            }
    
            private fun factor(n: Int): String {
              for (i in 2 until n) {
                val x = n / i
                if (x * i == n) return "${factor(x)} × $i"
              }
              return n.toString()
            }
          }
    
        val request =
          Request(
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.9K bytes
    - Click Count (0)
  8. android/guava-testlib/src/com/google/common/collect/testing/testers/CollectionCreationTester.java

            });
      }
    
      /**
       * Returns the {@link Method} instance for {@link #testCreateWithNull_unsupported()} so that tests
       * can suppress it with {@code FeatureSpecificTestSuiteBuilder.suppressing()} until <a
       * href="https://bugs.openjdk.org/browse/JDK-5045147">JDK-5045147</a> is fixed.
       */
      @J2ktIncompatible
      @GwtIncompatible // reflection
      public static Method getCreateWithNullUnsupportedMethod() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 3K bytes
    - Click Count (0)
  9. internal/s3select/message.go

    		close(writer.payloadCh)
    		// Wait until the `start` go-routine is done.
    		<-writer.doneCh
    		return nil
    	}
    }
    
    func (writer *messageWriter) FinishWithError(errorCode, errorMessage string) error {
    	select {
    	case <-writer.doneCh:
    		return fmt.Errorf("messageWriter is done")
    	case writer.errCh <- newErrorMessage([]byte(errorCode), []byte(errorMessage)):
    		// Wait until the `start` go-routine is done.
    		<-writer.doneCh
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  10. build-logic/build-update-utils/src/main/kotlin/gradlebuild/buildutils/tasks/AbstractVersionsUpdateTask.kt

                setAttribute(XMLConstants.ACCESS_EXTERNAL_SCHEMA, "")
            }.newDocumentBuilder()
                .parse(url)
                .getElementsByTagName("version").let { versions ->
                    (0 until versions.length)
                        .map { idx -> (versions.item(idx) as Element).textContent }
                        .reversed()
                }
    
        protected
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Fri Oct 24 09:10:28 GMT 2025
    - 3.4K bytes
    - Click Count (0)
Back to Top