- Sort Score
- Num 10 results
- Language All
Results 171 - 180 of 303 for awaited (0.04 seconds)
-
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()Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 15.4K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
* <li>calls {@link ExecutorService#shutdown()}, disabling acceptance of new submitted tasks. * <li>awaits executor service termination for half of the specified timeout. * <li>if the timeout expires, it calls {@link ExecutorService#shutdownNow()}, cancelling * pending tasks and interrupting running tasks. * <li>awaits executor service termination for the other half of the specified timeout. * </ol> *
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Oct 08 18:55:33 GMT 2025 - 45.2K bytes - Click Count (0) -
guava/src/com/google/common/collect/Platform.java
* * @param reference any array of the desired type * @param length the length of the new array */ /* * The new array contains nulls, even if the old array did not. If we wanted to be accurate, we * would declare a return type of `@Nullable T[]`. However, we've decided not to think too hard * about arrays for now, as they're a mess. (We previously discussed this in the review of
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 5.5K bytes - Click Count (0) -
docs/zh/docs/advanced/events.md
```Python with open("file.txt") as file: file.read() ``` Python 的最近几个版本也有了一个**异步上下文管理器**,你可以通过 `async with` 来使用: ```Python async with lifespan(app): await do_stuff() ``` 你可以像上面一样创建了一个上下文管理器或者异步上下文管理器,它的作用是在进入 `with` 块时,执行 `yield` 之前的代码,并且在离开 `with` 块时,执行 `yield` 后面的代码。 但在我们上面的例子里,我们并不是直接使用,而是传递给 FastAPI 来供其使用。
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Oct 11 17:48:49 GMT 2025 - 7K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/CacheStats.java
* missRate =~ 1.0}. Cache misses include all requests which weren't cache hits, including * requests which resulted in either successful or failed loading attempts, and requests which * waited for other threads to finish loading. It is thus the case that {@code missCount >= * loadSuccessCount + loadExceptionCount}. Multiple concurrent misses for the same key will result * in a single load operation. */
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Jul 08 18:32:10 GMT 2025 - 12.6K bytes - Click Count (0) -
guava/src/com/google/common/cache/CacheStats.java
* missRate =~ 1.0}. Cache misses include all requests which weren't cache hits, including * requests which resulted in either successful or failed loading attempts, and requests which * waited for other threads to finish loading. It is thus the case that {@code missCount >= * loadSuccessCount + loadExceptionCount}. Multiple concurrent misses for the same key will result * in a single load operation. */
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Jul 08 18:32:10 GMT 2025 - 12.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
fail("") } }, ) assertThat(server.takeRequest().exchangeIndex) .isEqualTo(expectedSequenceNumber) responseDequeuedLatch!!.await() call.cancel() requestCanceledLatch!!.countDown() latch.await() } @Test fun noRecoveryFromRefusedStreamWithRetryDisabled() { noRecoveryFromErrorWithRetryDisabled(ErrorCode.REFUSED_STREAM) } @Test
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 67.4K bytes - Click Count (0) -
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"> ```consoleCreated: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Oct 11 17:48:49 GMT 2025 - 7.1K bytes - Click Count (0) -
internal/lsync/lrwmutex_test.go
expected := false if locked != expected { t.Errorf("TestDualWriteLockTimedOut(): \nexpected %#v\ngot %#v", expected, locked) } } // Test cases below are copied 1 to 1 from sync/rwmutex_test.go (adapted to use LRWMutex) // Borrowed from rwmutex_test.go func parallelReader(ctx context.Context, m *LRWMutex, clocked, cunlock, cdone chan bool) { if m.GetRLock(ctx, "", "", time.Second) { clocked <- true <-cunlockCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 7.8K bytes - Click Count (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
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Jul 16 17:42:14 GMT 2025 - 15.8K bytes - Click Count (0)