- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 285 for awaited (0.05 sec)
-
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) -
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) -
docs/de/docs/advanced/events.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Nov 18 02:25:44 UTC 2024 - 9K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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)