Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 272 for awaiter (0.04 sec)

  1. android-test/src/test/kotlin/okhttp/android/test/AndroidSocketAdapterTest.kt

        assertTrue(adapter.matchesSocket(sslSocket))
    
        adapter.configureTlsExtensions(sslSocket, null, listOf(HTTP_2, HTTP_1_1))
        // not connected
        assertNull(adapter.getSelectedProtocol(sslSocket))
      }
    
      @Test
      fun testMatchesSupportedAndroidSocketFactory() {
        assumeTrue(adapter is StandardAndroidSocketAdapter)
    
        assertTrue(adapter.matchesSocketFactory(context.socketFactory))
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/collect/QueuesTest.java

        try {
          // if waiting works, this should get stuck
          Queues.drain(q, new ArrayList<>(), 1, MAX_VALUE, NANOSECONDS);
          fail();
        } catch (InterruptedException expected) {
          // we indeed waited; a slow thread had enough time to interrupt us
        }
      }
    
      // same as above; uninterruptible version
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Nov 04 17:24:58 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  3. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerWriter.kt

      /** Names leading to the current location in the ASN.1 document. */
      private val path = mutableListOf<String>()
    
      /**
       * False unless we made a recursive call to [write] at the current stack frame. The explicit box
       * adapter can clear this to synthesize non-constructed values that are embedded in octet strings.
       */
      var constructed = false
    
      fun write(
        name: String,
        tagClass: Int,
        tag: Long,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

          }
          if (associatedStreamId == 0) {
            writer.headers(outFinished, streamId, requestHeaders)
          } else {
            require(!client) { "client streams shouldn't have associated stream IDs" }
            // HTTP/2 has a PUSH_PROMISE frame.
            writer.pushPromise(associatedStreamId, streamId, requestHeaders)
          }
        }
    
        if (flushHeaders) {
          writer.flush()
        }
    
        return stream
      }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/io/AppendableWriterTest.java

        StringBuilder builder = new StringBuilder();
        Writer writer = new AppendableWriter(builder);
    
        writer.write("Hello".toCharArray());
        writer.write(',');
        writer.write(0xBEEF0020); // only lower 16 bits are important
        writer.write("Wo");
        writer.write("Whirled".toCharArray(), 3, 2);
        writer.write("Mad! Mad, I say", 2, 2);
    
        assertEquals("Hello, World!", builder.toString());
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed May 14 19:40:47 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  6. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlanLogger.java

            }
        }
    
        public void writePlan(Consumer<String> writer, BuildPlan plan) {
            plan.projects().forEach(project -> writePlan(writer, plan, project));
        }
    
        public void writePlan(Consumer<String> writer, BuildPlan plan, MavenProject project) {
            writer.accept("=== PROJECT BUILD PLAN ================================================");
            writer.accept("Project:                     " + getKey(project));
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Sun Mar 30 23:08:36 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  7. utils/tests/dummy_dialecter.go

    	return clause.Expr{SQL: "DEFAULT"}
    }
    
    func (DummyDialector) Migrator(*gorm.DB) gorm.Migrator {
    	return nil
    }
    
    func (DummyDialector) BindVarTo(writer clause.Writer, stmt *gorm.Statement, v interface{}) {
    	writer.WriteByte('?')
    }
    
    func (DummyDialector) QuoteTo(writer clause.Writer, str string) {
    	var (
    		underQuoted, selfQuoted bool
    		continuousBacktick      int8
    		shiftDelimiter          int8
    	)
    
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Mon Mar 06 06:03:31 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  8. src/test/java/jcifs/netbios/LmhostsTest.java

            File lmhostsFile = tempDir.resolve("lmhosts_empty").toFile();
            try (FileWriter writer = new FileWriter(lmhostsFile)) {
                writer.write("192.168.1.100 HOST1\n");
                writer.write("\n");
                writer.write("   \n");
                writer.write("192.168.1.101 HOST2\n");
            }
    
            when(mockConfig.getLmHostsFileName()).thenReturn(lmhostsFile.getAbsolutePath());
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 18.2K bytes
    - Viewed (0)
  9. docs/fr/docs/tutorial/background-tasks.md

        * Étant donné que se connecter à un serveur et envoyer un email a tendance à être «lent» (plusieurs secondes), vous pouvez retourner la réponse directement et envoyer la notification en arrière-plan.
    * Traiter des données :
        * Par exemple, si vous recevez un fichier qui doit passer par un traitement lent, vous pouvez retourner une réponse «Accepted» (HTTP 202) puis faire le traitement en arrière-plan.
    
    
    ## Utiliser `BackgroundTasks`
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Oct 11 17:48:49 UTC 2025
    - 5.5K bytes
    - Viewed (0)
  10. compat/maven-toolchain-builder/src/main/java/org/apache/maven/toolchain/building/ToolchainsBuildingException.java

            PrintWriter writer = new PrintWriter(buffer);
    
            writer.print(problems.size());
            writer.print((problems.size() == 1) ? " problem was " : " problems were ");
            writer.print("encountered while building the effective toolchains");
            writer.println();
    
            for (Problem problem : problems) {
                writer.print("[");
                writer.print(problem.getSeverity());
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Mar 05 09:37:42 UTC 2025
    - 2.7K bytes
    - Viewed (0)
Back to top