- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 177 for instantly (0.3 sec)
-
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultConditionalExecutionQueueTest.groovy
def execution = testExecution({ instant.executionStarted println("I'm running!") thread.block() instant.executionFinished }) when: async { queue.submit(execution) execution.await() instant.awaitFinished } then: instant.awaitFinished > instant.executionFinished }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 6.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/HeadersJvmTest.kt
} @Test fun setInstant() { val expected = Instant.ofEpochMilli(1000L) val headers = Headers.Builder() .add("Test-Instant", Instant.ofEpochMilli(0L)) .set("Test-Instant", expected) .build() assertThat(headers["Test-Instant"]).isEqualTo("Thu, 01 Jan 1970 00:00:01 GMT") assertThat(headers.getInstant("Test-Instant")).isEqualTo(expected) } @Test fun addParsing() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.6K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/NamedOperation.groovy
} Instant getEnd() { def instant = end.get() if (instant == null) { throw new IllegalStateException("Operation '$name' has not completed yet.") } return instant } Duration getDuration() { return getEnd() - start } void completed(Instant when) { end.compareAndSet(null, when) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/actor/internal/DefaultActorFactorySpec.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 8.1K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultCacheCleanupExecutor.java
getLastCleanupTime() .ifPresent(this::performCleanupIfNecessary); } private void performCleanupIfNecessary(Instant lastCleanupTime) { if (LOGGER.isDebugEnabled()) { Duration timeSinceLastCleanup = Duration.between(lastCleanupTime, Instant.now()); LOGGER.debug("{} has last been fully cleaned up {} hours ago", cleanableStore.getDisplayName(), timeSinceLastCleanup.toHours()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 14 16:53:17 UTC 2024 - 5.7K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/test/groovy/org/gradle/api/internal/tasks/userinput/DefaultUserInputReaderTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 1.6K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/loader/SynchronizedToolingImplementationLoaderTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 2.9K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/DefaultPhasedBuildActionExecuterTest.groovy
instant.dispatched < instant.resultAvailable instant.resultAvailable < instant.resultReceived } def "run() blocks until result is available"() { given: asyncConnection.run(!null, !null) >> { def consumerAction, ResultHandlerVersion1 adaptedHandler -> start { thread.block() instant.resultAvailable adaptedHandler.onComplete(null)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 6K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/event/DefaultListenerManagerTest.groovy
} then: instant.bReceived > instant.aHandled } def notifyDoesNotBlockWhenAnotherThreadIsNotifyingOnDifferentType() { given: def listener1 = { String p -> instant.aReceived thread.block() instant.aHandled } as TestFooListener def listener2 = { instant.bReceived } as TestBarListener
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 29.1K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/DefaultBuildLauncherTest.groovy
instant.dispatched < instant.resultAvailable instant.resultAvailable < instant.resultReceived } def "run() blocks until build is finished"() { given: asyncConnection.run(!null, !null) >> { args -> def handler = args[1] start { thread.block() instant.resultAvailable handler.onComplete(null) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 11.4K bytes - Viewed (0)