- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 980 for Await (0.04 sec)
-
guava-testlib/test/com/google/common/testing/FakeTickerTest.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 06 14:40:46 UTC 2024 - 6.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/DispatcherTest.java
final CountDownLatch latch = new CountDownLatch(2); new Thread( new Runnable() { @Override public void run() { try { barrier.await(); } catch (Exception e) { throw new AssertionError(e); } dispatcher.dispatch(2, integerSubscribers.iterator()); latch.countDown();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 27 15:41:25 UTC 2022 - 5.6K bytes - Viewed (0) -
okhttp/src/test/java/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: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.1K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/ConditionalExecution.java
*/ Runnable getExecution(); /** * Blocks waiting for this execution to complete. Returns a result provided by the execution. */ T await(); /** * This method will be called upon completion of the execution. */ void complete(); /** * Whether this execution has been completed or not. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.2K bytes - Viewed (0) -
tests/test_dependency_contextvars.py
legacy_request_state_context_var.reset(contextvar_token) @app.middleware("http") async def custom_middleware( request: Request, call_next: Callable[[Request], Awaitable[Response]] ): response = await call_next(request) response.headers["custom"] = "foo" return response @app.get("/user", dependencies=[Depends(set_up_request_state_dependency)]) def get_user():
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Feb 17 12:40:12 UTC 2022 - 1.5K bytes - Viewed (0) -
docs/em/docs/advanced/websockets.md
``` !!! note "đĄ âš" đ đĒ âī¸ `from starlette.websockets import WebSocket`. **FastAPI** đ đ `WebSocket` đ đĒ đ, đŠâđģ. âī¸ âĢī¸ đ đ âĒī¸âĄī¸ đ. ## â đ§ & đ¨ đ§ đ *ī¸âŖ đŖ đ đĒ `await` đ§ & đ¨ đ§. ```Python hl_lines="48-52" {!../../../docs_src/websockets/tutorial001.py!} ``` đ đĒ đ¨ & đ¨ đą, â, & đģ đŊ. ## đ âĢī¸ đĨ đ đ đ `main.py`, đ đ đ¸ âŽī¸:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Apr 01 09:26:04 UTC 2023 - 4.8K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/process/internal/MessageProducingProcess.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 05 18:05:20 UTC 2017 - 1.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/deployment/internal/SimpleBlockingDeployment.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Feb 23 18:00:07 UTC 2022 - 2.1K bytes - Viewed (0) -
docs/ko/docs/tutorial/request-files.md
* `seek(offset)`: íėŧ ë´ `offset`(`int`) ėėšė ë°ė´í¸ëĄ ė´ëíŠëë¤. * ė) `await myfile.seek(0)` ëĨŧ ėŦėŠí늴 íėŧė ėėëļëļėŧëĄ ė´ëíŠëë¤. * `await myfile.read()` ëĨŧ ėŦėŠí í ë´ėŠė ë¤ė ėŊė ë ė ėŠíŠëë¤. * `close()`: íėŧė ëĢėĩëë¤. ė기 ëĒ¨ë ëŠėëë¤ė´ `async` ëŠėëė´ę¸° ëëŦ¸ė âawaitâė ėŦėŠíėŦėŧ íŠëë¤. ėëĨŧë¤ė´, `async` *ę˛ŊëĄ ėë í¨ė*ė ë´ëļėė ë¤ėęŗŧ ę°ė ë°ŠėėŧëĄ ë´ėŠė ę°ė ¸ėŦ ė ėėĩëë¤: ```Python contents = await myfile.read() ```
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Mar 13 19:02:19 UTC 2024 - 8.1K bytes - Viewed (0) -
platforms/core-runtime/build-operations/src/test/groovy/org/gradle/internal/operations/CurrentBuildOperationRefTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 14:19:43 UTC 2023 - 1.5K bytes - Viewed (0)