- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 786 for Await (0.04 sec)
-
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/concurrent/future.kt
override fun isDone(): Boolean = result != null override fun get(): T { outcomeLatch.await() return getOrThrow() } override fun get(timeout: Long, unit: TimeUnit): T = if (outcomeLatch.await(timeout, unit)) getOrThrow() else throw TimeoutException() private fun getOrThrow() = (result as Result<T>).getOrThrow()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 2.2K bytes - Viewed (0) -
platforms/extensibility/unit-test-fixtures/src/integTest/groovy/org/gradle/testfixtures/ProjectBuilderIntegrationTest.groovy
def threads = 5 def startSignal = new CountDownLatch(1) def doneSignal = new CountDownLatch(threads) when: threads.times { new Thread({ startSignal.await() def spawnedProject = ProjectBuilder.builder().build() try { doneSignal.countDown() } finally {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 13 21:54:27 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkQueueIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:36:27 UTC 2023 - 8.7K bytes - Viewed (0) -
docs/de/docs/advanced/async-tests.md
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 30 20:25:57 UTC 2024 - 4.4K bytes - Viewed (0) -
docs/en/docs/advanced/async-tests.md
Then we can create an `AsyncClient` with the app, and send async requests to it, using `await`. ```Python hl_lines="9-10" {!../../../docs_src/async_tests/test_main.py!} ``` This is the equivalent to: ```Python response = client.get('/') ``` ...that we used to make our requests with the `TestClient`. !!! tip Note that we're using async/await with the new `AsyncClient` - the request is asynchronous. !!! warning
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Jan 13 12:07:15 UTC 2024 - 3.9K bytes - Viewed (0) -
docs/zh/docs/tutorial/request-files.md
* `read(size)`:按指定数量的字节或字符(`size` (`int`))读取文件内容; * `seek(offset)`:移动至文件 `offset` (`int`)字节处的位置; * 例如,`await myfile.seek(0) ` 移动到文件开头; * 执行 `await myfile.read()` 后,需再次读取已读取内容时,这种方法特别好用; * `close()`:关闭文件。 因为上述方法都是 `async` 方法,要搭配「await」使用。 例如,在 `async` *路径操作函数* 内,要用以下方式读取文件内容: ```Python contents = await myfile.read() ``` 在普通 `def` *路径操作函数* 内,则可以直接访问 `UploadFile.file`,例如: ```Python
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Mar 13 19:02:19 UTC 2024 - 6.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/SharedResourceLeaseRegistryTest.groovy
assert lockIsHeld(sharedResourceLock) coordinationService.withStateLock(unlock(sharedResourceLock)) } } started.await() instant.releaseAll } then: noExceptionThrown() } def "locks on different shared resources can be concurrently held"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
throw RuntimeException("boom!") } queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(200)) { log.put("normal task running") return@schedule -1L } queue.idleLatch().await(500, TimeUnit.MILLISECONDS) assertThat(log.take()).isEqualTo("failing task running") assertThat(log.take()).isEqualTo("uncaught exception: java.lang.RuntimeException: boom!")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/extensibility/test-kit/src/integTest/groovy/org/gradle/testkit/runner/GradleRunnerResultIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 22:36:52 UTC 2023 - 4.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/integTest/groovy/org/gradle/internal/remote/UnicastMessagingIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 09:21:43 UTC 2024 - 8.9K bytes - Viewed (0)