Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 507 for await (0.03 sec)

  1. android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java

                      startLatch.countDown();
                      startLatch.await();
                      callable.call();
                      doneLatch.countDown();
                      return null;
                    }
                  });
        }
        doneLatch.await();
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt

            .build()
        }
        val request =
          Request
            .Builder()
            .url(server.url("/"))
            .build()
        client.newCall(request).enqueue(callback)
        callback
          .await(request.url)
          .assertCode(200)
          .assertHeader("OkHttp-Intercepted", "yep")
      }
    
      @Test
      fun applicationInterceptorsCanMakeMultipleRequestsToServer() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 28.2K bytes
    - Viewed (0)
  3. docs/ko/docs/advanced/websockets.md

    `from starlette.websockets import WebSocket`을 사용할 수도 있습니다.
    
    **FastAPI**는 개발자를 위한 편의를 위해 동일한 `WebSocket`을 직접 제공합니다. 하지만 이는 Starlette에서 가져옵니다.
    
    ///
    
    ## 메시지를 대기하고 전송하기
    
    WebSocket 경로에서 메시지를 대기(`await`)하고 전송할 수 있습니다.
    
    {* ../../docs_src/websockets/tutorial001.py hl[48:52] *}
    
    여러분은 이진 데이터, 텍스트, JSON 데이터를 받을 수 있고 전송할 수 있습니다.
    
    ## 시도해보기
    
    파일 이름이 `main.py`라고 가정하고 응용 프로그램을 실행합니다:
    
    <div class="termy">
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Wed Nov 27 20:03:29 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/RecordingCallback.kt

        (this as Object).notifyAll()
      }
    
      /**
       * Returns the recorded response triggered by `request`. Throws if the response isn't
       * enqueued before the timeout.
       */
      @Synchronized
      fun await(url: HttpUrl): RecordedResponse {
        val timeoutMillis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime()) + TIMEOUT_MILLIS
        while (true) {
          val i = responses.iterator()
          while (i.hasNext()) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  5. mockwebserver/src/main/kotlin/mockwebserver3/internal/MockWebServerSocket.kt

        }
      }
    
      override fun cancel() {
        delegate.cancel()
      }
    
      override fun close() {
        javaNetSocket.close()
      }
    
      fun awaitClosed() {
        closedLatch.await()
      }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  6. src/test/java/jcifs/smb/NtlmPasswordAuthenticatorTest.java

                    }
                }).start();
            }
    
            // Start all threads simultaneously
            startLatch.countDown();
    
            // Wait for completion
            assertTrue(completeLatch.await(5, TimeUnit.SECONDS));
    
            // Authenticator should be closed
            assertTrue(auth.isClosed());
        }
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 23.3K bytes
    - Viewed (0)
  7. src/test/java/jcifs/internal/smb2/Smb2EncryptionContextTest.java

            for (int t = 0; t < threadCount; t++) {
                final int threadId = t;
                executor.submit(() -> {
                    try {
                        startLatch.await(); // Wait for all threads to be ready
    
                        for (int i = 0; i < operationsPerThread; i++) {
                            String message = String.format("Thread-%d-Message-%d", threadId, i);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 44.1K bytes
    - Viewed (0)
  8. docs/ja/docs/advanced/websockets.md

    /// note | 技術詳細
    
    `from starlette.websockets import WebSocket` を使用しても構いません.
    
    **FastAPI** は開発者の利便性のために、同じ `WebSocket` を提供します。しかし、こちらはStarletteから直接提供されるものです。
    
    ///
    
    ## メッセージの送受信
    
    WebSocketルートでは、 `await` を使ってメッセージの送受信ができます。
    
    {* ../../docs_src/websockets/tutorial001.py hl[48:52] *}
    
    バイナリやテキストデータ、JSONデータを送受信できます。
    
    ## 試してみる
    
    ファイル名が `main.py` である場合、以下の方法でアプリケーションを実行します。
    
    <div class="termy">
    
    ```console
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  9. docs/ko/docs/advanced/events.md

    ```Python
    with open("file.txt") as file:
        file.read()
    ```
    최근 버전의 파이썬에서는 **비동기 컨텍스트 매니저**도 있습니다. 이를 `async with`와 함께 사용합니다:
    
    ```Python
    async with lifespan(app):
        await do_stuff()
    ```
    
    컨텍스트 매니저나 위와 같은 비동기 컨텍스트 매니저를 만들면, `with` 블록에 들어가기 전에 `yield` 이전의 코드가 실행되고, `with` 블록을 벗어난 후에는 `yield` 이후의 코드가 실행됩니다.
    
    위의 코드 예제에서는 직접 사용하지 않고, FastAPI에 전달하여 사용하도록 합니다.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri May 30 13:33:53 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  10. docs/fr/docs/tutorial/background-tasks.md

    Dans cet exemple, la fonction de tâche écrira dans un fichier (afin de simuler un envoi d'email).
    
    L'opération d'écriture n'utilisant ni `async` ni `await`, on définit la fonction avec un `def` normal.
    
    {* ../../docs_src/background_tasks/tutorial001.py hl[6:9] *}
    
    ## Ajouter une tâche d'arrière-plan
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Nov 10 17:23:38 UTC 2024
    - 5.4K bytes
    - Viewed (0)
Back to top