Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 285 for awaited (0.05 sec)

  1. cmd/handler-api.go

    			globalHTTPStats.addRequestsInQueue(-1)
    			// When the client disconnects before getting the S3 handler
    			// status code response, set the status code to 499 so this request
    			// will be properly audited and traced.
    			w.WriteHeader(499)
    		default:
    			globalHTTPStats.addRequestsInQueue(-1)
    			if contextCanceled(ctx) {
    				w.WriteHeader(499)
    				return
    			}
    			// Send a http timeout message
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  2. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

          Future<?> possiblyIgnoredError = executorService.submit(executeTask);
          returnValue += (int) listenerLatch.getCount();
          listenerLatch.await();
        }
        return returnValue;
      }
    
      @Benchmark
      int executeThenAdd_multiThreaded(int reps) throws InterruptedException {
        Runnable addTask =
            new Runnable() {
              @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  3. docs/de/docs/advanced/events.md

    with open("file.txt") as file:
        file.read()
    ```
    
    In neueren Versionen von Python gibt es auch einen **asynchronen Kontextmanager**. Sie würden ihn mit `async with` verwenden:
    
    ```Python
    async with lifespan(app):
        await do_stuff()
    ```
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 9K 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. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt

      override fun ensureLoaded() {
        if (!listRead.get() && listRead.compareAndSet(false, true)) {
          readTheListUninterruptibly()
        } else {
          try {
            readCompleteLatch.await()
          } catch (_: InterruptedException) {
            Thread.currentThread().interrupt() // Retain interrupted status.
          }
        }
    
        if (!::bytes.isInitialized) {
          // May have failed with an IOException
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 28 07:33:49 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  6. docs/es/docs/advanced/dataclasses.md

        Como siempre, en FastAPI puedes combinar `def` y `async def` según sea necesario.
    
        Si necesitas un repaso sobre cuándo usar cuál, revisa la sección _"¿Con prisa?"_ en la documentación sobre [`async` y `await`](../async.md#in-a-hurry){.internal-link target=_blank}.
    
    9. Esta *path operation function* no está devolviendo dataclasses (aunque podría), sino una lista de diccionarios con datos internos.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Dec 30 18:26:57 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. docs/pt/docs/advanced/dataclasses.md

        Como sempre, no FastAPI você pode combinar `def` e `async def` conforme necessário.
    
        Se você precisar de uma atualização sobre quando usar qual, confira a seção _"Com pressa?"_ na documentação sobre [`async` e `await`](../async.md#in-a-hurry){.internal-link target=_blank}.
    
    9. Esta *função de operação de rota* não está retornando dataclasses (embora pudesse), mas uma lista de dicionários com dados internos.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  8. docs/uk/docs/tutorial/background-tasks.md

    Вона може бути асинхронною `async def` або звичайною `def` функцією – **FastAPI** обробить її правильно.
    
    У нашому випадку функція записує у файл (імітуючи надсилання email).
    
    І оскільки операція запису не використовує `async` та `await`, ми визначаємо функцію як звичайну `def`:
    
    {* ../../docs_src/background_tasks/tutorial001.py hl[6:9] *}
    
    ## Додавання фонової задачі
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri May 30 13:34:53 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb/NtlmPasswordAuthenticatorTest.java

            for (int i = 0; i < threadCount; i++) {
                final int index = i;
                new Thread(() -> {
                    try {
                        startLatch.await();
    
                        if (index % 3 == 0) {
                            // Some threads wipe password
                            auth.secureWipePassword();
                        } else if (index % 3 == 1) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 23.3K bytes
    - Viewed (0)
  10. cmd/auth-handler_test.go

    	}
    	for i, testCase := range testCases {
    		if _, s3Error := checkAdminRequestAuth(ctx, testCase.Request, policy.AllAdminActions, globalSite.Region()); s3Error != testCase.ErrCode {
    			t.Errorf("Test %d: Unexpected s3error returned wanted %d, got %d", i, testCase.ErrCode, s3Error)
    		}
    	}
    }
    
    func TestValidateAdminSignature(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 15.4K bytes
    - Viewed (0)
Back to top