Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 609 for await (0.03 sec)

  1. okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt

              call: Call,
              inetSocketAddress: InetSocketAddress,
              proxy: Proxy,
            ) {
              try {
                // Wait for request2 to guarantee we make 2 separate connections to the server.
                latch1.await()
              } catch (e: InterruptedException) {
                throw AssertionError(e)
              }
            }
    
            override fun connectionAcquired(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

        assertEquals(3L, countDownLatch.getCount());
    
        list.execute();
    
        // Verify that all of the runnables execute in a reasonable amount of time.
        assertTrue(countDownLatch.await(1L, SECONDS));
      }
    
      public void testExecute_idempotent() {
        final AtomicInteger runCalled = new AtomicInteger();
        list.add(
            new Runnable() {
              @Override
              public void run() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  3. docs/de/docs/advanced/async-tests.md

    Dann können wir einen `AsyncClient` mit der App erstellen und mit `await` asynchrone Requests an ihn senden.
    
    {* ../../docs_src/async_tests/test_main.py hl[9:12] *}
    
    Das ist das Äquivalent zu:
    
    ```Python
    response = client.get('/')
    ```
    
    ... welches wir verwendet haben, um unsere Requests mit dem `TestClient` zu machen.
    
    /// tip | "Tipp"
    
    Beachten Sie, dass wir async/await mit dem neuen `AsyncClient` verwenden – der Request ist asynchron.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 15:34:47 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. docs/en/docs/advanced/async-tests.md

    ///
    
    Then we can create an `AsyncClient` with the app, and send async requests to it, using `await`.
    
    {* ../../docs_src/async_tests/test_main.py hl[9:12] *}
    
    This is the equivalent to:
    
    ```Python
    response = client.get('/')
    ```
    
    ...that we used to make our requests with the `TestClient`.
    
    /// tip
    
    Note that we're using async/await with the new `AsyncClient` - the request is asynchronous.
    
    ///
    
    /// warning
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 15:43:29 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  5. guava-testlib/src/com/google/common/testing/GcFinalization.java

     * Object x = new MyClass() {
     *   ...
     *   protected void finalize() { latch.countDown(); ... }
     * };
     * x = null;  // Hint to the JIT that x is stack-unreachable
     * GcFinalization.await(latch);
     * }</pre>
     *
     * <p>Here's an example that uses a user-defined finalization predicate:
     *
     * <pre>{@code
     * final WeakHashMap<Object, Object> map = new WeakHashMap<>();
     * map.put(new Object(), Boolean.TRUE);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  6. docs/ja/docs/async.md

    # 並行処理と async / await
    
    *path operation 関数*のための `async def` に関する詳細と非同期 (asynchronous) コード、並行処理 (Concurrency)、そして、並列処理 (Parallelism) の背景について。
    
    ## 急いでいますか?
    
    <abbr title="too long; didn't read (長すぎて読めない人のための要約という意味のスラング)"><strong>TL;DR:</strong></abbr>
    
    次のような、`await` を使用して呼び出すべきサードパーティライブラリを使用している場合:
    
    ```Python
    results = await some_library()
    ```
    
    以下の様に `async def` を使用して*path operation 関数*を宣言します。
    
    ```Python hl_lines="2"
    @app.get('/')
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

                                  // WAIT #1
                                  barrier.await(1, SECONDS);
    
                                  // WAIT #2
                                  barrier.await(1, SECONDS);
                                  assertTrue(executor.isShutdown());
                                  assertFalse(executor.isTerminated());
    
                                  // WAIT #3
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  8. .github/workflows/create_issue.js

      const repo = context.payload.repository.name;
      console.log(`Original PR: ${pr_number} and Rollback Commit: ${rollback_commit}`);
      // Get the Original PR Details
      const pr_resp = await github.rest.pulls.get({
        owner,
        repo,
        pull_number: pr_number
      });
      if (pr_resp.status != 200 || pr_resp.data.state != 'closed') {
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 18 23:04:59 UTC 2021
    - 2.8K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      //      */
      //     public void await(AtomicBoolean flag) {
      //         await(flag, LONG_DELAY_MS);
      //     }
    
      //     /**
      //      * Spin-waits up to the specified timeout until flag becomes true.
      //      */
      //     public void await(AtomicBoolean flag, long timeoutMillis) {
      //         long startTime = System.nanoTime();
      //         while (!flag.get()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      //      */
      //     public void await(AtomicBoolean flag) {
      //         await(flag, LONG_DELAY_MS);
      //     }
    
      //     /**
      //      * Spin-waits up to the specified timeout until flag becomes true.
      //      */
      //     public void await(AtomicBoolean flag, long timeoutMillis) {
      //         long startTime = System.nanoTime();
      //         while (!flag.get()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
Back to top