- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 272 for awaiter (0.15 sec)
-
docs/fr/docs/deployment/manually.md
* la mémoire * les étapes précédant le démarrage
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Oct 11 17:48:49 UTC 2025 - 5.3K bytes - Viewed (0) -
docs/fr/docs/tutorial/body-multiple-params.md
Si vous le déclarez tel quel, comme c'est une valeur [scalaire](https://docs.github.com/fr/graphql/reference/scalars), **FastAPI** supposera qu'il s'agit d'un paramètre de requête (`Query`). Mais vous pouvez indiquer à **FastAPI** de la traiter comme une variable de body en utilisant `Body` : {* ../../docs_src/body_multiple_params/tutorial003_an_py310.py hl[23] *} Dans ce cas, **FastAPI** s'attendra à un body semblable à : ```JSON { "item": {
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Nov 09 11:10:17 UTC 2024 - 5.6K bytes - Viewed (0) -
cmd/lock-rest-server-common_test.go
defer os.RemoveAll(testPath) lockRequesterInfo1 := lockRequesterInfo{ Owner: "owner", Writer: true, UID: "0123-4567", Timestamp: UTCNow().UnixNano(), TimeLastRefresh: UTCNow().UnixNano(), } lockRequesterInfo2 := lockRequesterInfo{ Owner: "owner", Writer: true, UID: "89ab-cdef", Timestamp: UTCNow().UnixNano(),
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 3.2K bytes - Viewed (0) -
cmd/local-locker.go
const lockMutexWaitLimit = 1000 // lockRequesterInfo stores various info from the client for each lock that is requested. type lockRequesterInfo struct { Name string // name of the resource lock was requested for Writer bool // Bool whether write or read lock. UID string // UID to uniquely identify request of client. Timestamp int64 // Timestamp set at the time of initialization.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 12K bytes - Viewed (0) -
docs_src/handling_errors/tutorial006_py39.py
async def custom_http_exception_handler(request, exc): print(f"OMG! An HTTP error!: {repr(exc)}") return await http_exception_handler(request, exc) @app.exception_handler(RequestValidationError) async def validation_exception_handler(request, exc): print(f"OMG! The client sent invalid data!: {exc}") return await request_validation_exception_handler(request, exc) @app.get("/items/{item_id}")
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 928 bytes - Viewed (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)
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 10 08:55:32 UTC 2025 - 947 bytes - Viewed (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)
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 10 08:55:32 UTC 2025 - 935 bytes - Viewed (0) -
docs_src/custom_request_and_route/tutorial001_an_py39.py
from fastapi import Body, FastAPI, Request, Response from fastapi.routing import APIRoute class GzipRequest(Request): async def body(self) -> bytes: if not hasattr(self, "_body"): body = await super().body() if "gzip" in self.headers.getlist("Content-Encoding"): body = gzip.decompress(body) self._body = body return self._body class GzipRoute(APIRoute):
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 10 08:55:32 UTC 2025 - 988 bytes - Viewed (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());
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 12.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt
ready.countDown() try { proceed.await(5, TimeUnit.SECONDS) } catch (e: InterruptedException) { throw RuntimeException(e) } chain.proceed(chain.request()) }, ).build() val t1 = makeSynchronousCall(client.newCall(newRequest("http://a/3"))) ready.await(5, TimeUnit.SECONDS) executor.finishJob("http://a/2")
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 15.8K bytes - Viewed (0)