- Sort Score
- Num 10 results
- Language All
Results 51 - 60 of 308 for awaited (0.04 seconds)
-
cmd/streaming-signature-v4_test.go
{"000000000000bogus", 0, "invalid byte in chunk length"}, {"00000000000000000", 0, "http chunk length too large"}, // could accept if we wanted {"10000000000000000", 0, "http chunk length too large"}, {"00000000000000001", 0, "http chunk length too large"}, // could accept if we wanted } for i := uint64(0); i <= 1234; i++ { tests = append(tests, testCase{in: fmt.Sprintf("%x", i), want: i}) } for _, tt := range tests {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.7K bytes - Click Count (0) -
cmd/tier-last-day-stats_gen.go
var zb0006 uint32 zb0006, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err, zb0001, "Bins") return } if zb0006 != uint32(24) { err = msgp.ArrayError{Wanted: uint32(24), Got: zb0006} return } for zb0003 := range zb0002.Bins { err = zb0002.Bins[zb0003].DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, zb0001, "Bins", zb0003) return
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 9.2K bytes - Click Count (0) -
docs/es/docs/tutorial/request-files.md
* `seek(offset)`: Va a la posición de bytes `offset` (`int`) en el archivo. * Por ejemplo, `await myfile.seek(0)` iría al inicio del archivo. * Esto es especialmente útil si ejecutas `await myfile.read()` una vez y luego necesitas leer el contenido nuevamente. * `close()`: Cierra el archivo. Como todos estos métodos son métodos `async`, necesitas "await" para ellos.Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Tue Dec 16 16:33:45 GMT 2025 - 7.9K bytes - Click Count (0) -
fastapi/concurrency.py
exit_limiter = CapacityLimiter(1) try: yield await run_in_threadpool(cm.__enter__) except Exception as e: ok = bool( await anyio.to_thread.run_sync( cm.__exit__, type(e), e, e.__traceback__, limiter=exit_limiter ) ) if not ok: raise e else: await anyio.to_thread.run_sync(
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 21:25:59 GMT 2025 - 1.5K bytes - Click Count (0) -
internal/crypto/header_test.go
// Test if result matches. t.Errorf("Requested mismatch, want %v, got %v", Requested(test.Header), got) } got = got && S3KMS.IsRequested(test.Header) if got != test.Expected { t.Errorf("SSE-KMS: Test %d: Wanted %v but got %v", i, test.Expected, got) } } for i, test := range s3IsRequestedTests { _, got := IsRequested(test.Header) if Requested(test.Header) != got { // Test if result matches.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Jul 13 14:52:15 GMT 2022 - 21.4K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
// Cause acceptConnections() to break out. serverSocket.closeQuietly() // Await shutdown. for (queue in taskRunner.activeQueues()) { if (!queue.idleLatch().await(5, TimeUnit.SECONDS)) { throw AssertionError("Gave up waiting for queue to shut down") } } taskRunnerBackend.shutdown() }Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Aug 02 20:36:00 GMT 2025 - 40.3K bytes - Click Count (0) -
docs_src/custom_request_and_route/tutorial002_an_py39.py
original_route_handler = super().get_route_handler() async def custom_route_handler(request: Request) -> Response: try: return await original_route_handler(request) except RequestValidationError as exc: body = await request.body() detail = {"errors": exc.errors(), "body": body.decode()} raise HTTPException(status_code=422, detail=detail)
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 10 08:55:32 GMT 2025 - 947 bytes - Click Count (0) -
docs_src/custom_request_and_route/tutorial002_py310.py
original_route_handler = super().get_route_handler() async def custom_route_handler(request: Request) -> Response: try: return await original_route_handler(request) except RequestValidationError as exc: body = await request.body() detail = {"errors": exc.errors(), "body": body.decode()} raise HTTPException(status_code=422, detail=detail)
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 10 08:55:32 GMT 2025 - 935 bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
assertFalse(service.startUpCalled); service.startAsync().awaitRunning(); assertTrue(service.startUpCalled); assertEquals(Service.State.RUNNING, service.state()); enterRun.await(); // to avoid stopping the service until run() is invoked service.stopAsync().awaitTerminated(); assertTrue(service.shutDownCalled); assertEquals(Service.State.TERMINATED, service.state());
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 16:03:47 GMT 2025 - 12.9K bytes - Click Count (0) -
docs/fr/docs/async.md
results = await some_library() ``` Alors, déclarez vos *fonctions de chemins* avec `async def` comme ceci : ```Python hl_lines="2" @app.get('/') async def read_results(): results = await some_library() return results ``` /// note Vous pouvez uniquement utiliser `await` dans les fonctions créées avec `async def`. /// ---
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sun Aug 31 09:56:21 GMT 2025 - 25.4K bytes - Click Count (0)