- Sort Score
- Num 10 results
- Language All
Results 31 - 40 of 109 for finishAdd (0.07 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskLogger.kt
completedNormally = true return result } finally { if (loggingEnabled) { val elapsedNs = queue.taskRunner.backend.nanoTime() - startNs if (completedNormally) { log(task, queue, "finished run in ${formatDuration(elapsedNs)}") } else { log(task, queue, "failed a run in ${formatDuration(elapsedNs)}") } } } } private fun Logger.log( task: Task, queue: TaskQueue,Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 2.6K bytes - Click Count (0) -
buildscripts/heal-manual.go
log.Fatalln(err) } fmt.Println() for { _, status, err := madmClnt.Heal(context.Background(), "healing-rewrite-bucket", "", opts, start.ClientToken, false, false) if status.Summary == "finished" { fmt.Println("Healstatus on items ===") for _, item := range status.Items { if err = enc.Encode(&item); err != nil { log.Fatalln(err) } } break }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 27 09:47:58 GMT 2024 - 2.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* to be closed asynchronously <b>after</b> the returned {@code Future} is done: the future * completes before closing starts, rather than once it has finished. * * {@snippet : * FluentFuture<UserName> userName = * ClosingFuture.submit( * closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor), * executor)
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Sep 11 13:51:27 GMT 2025 - 96.9K bytes - Click Count (0) -
scripts/sponsors.py
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Tue Dec 16 12:34:01 GMT 2025 - 6.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/eventbus/DispatcherTest.java
s1, s2, // those string subscribers aren't actually dispatched to until all integer s1, s2 // subscribers have finished. ) .inOrder(); } public void testLegacyAsyncDispatcher() { dispatcher = Dispatcher.legacyAsync(); CyclicBarrier barrier = new CyclicBarrier(2);Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 5.6K bytes - Click Count (0) -
scripts/deploy_docs_status.py
and comment.user.login == "github-actions[bot]" ): comment.edit(message) break else: issue.create_comment(message) logging.info("Finished") if __name__ == "__main__":Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Tue Sep 30 05:56:53 GMT 2025 - 4.4K bytes - Click Count (0) -
kotlin-js-store/yarn.lock
on-finished@2.4.1: version "2.4.1" resolved "https://registry.yarnpkg.com/on-finished/-/on-finished-2.4.1.tgz#58c8c44116e54845ad57f14ab10b03533184ac3f" integrity sha512-oVlzkg3ENAhCk2zdv7IJwd/QUD4z2RxRwpkcGY8psCVcCYZNq4wYnVWALHM+brtuJjePWiYF/ClmuDr8Ch5+kg== dependencies: ee-first "1.1.1" on-finished@~2.3.0: version "2.3.0"
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Jul 22 12:28:51 GMT 2023 - 87.4K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/ConcurrencyDependencyGraph.java
List<MavenProject> sortedResult = new ArrayList<>(result); sortedResult.sort(projectComparator.getComparator()); return sortedResult; } /** * Marks the provided project as finished. Returns a list of * * @param mavenProject The project * @return The list of builds that are eligible for starting now that the provided project is done */
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Jul 23 17:27:08 GMT 2025 - 5.9K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* reached the {@linkplain State#RUNNING running} state. * * @param timeout the maximum time to wait * @throws TimeoutException if not all of the services have finished starting within the deadline * @throws IllegalStateException if the service manager reaches a state from which it cannot * become {@linkplain #isHealthy() healthy}. * @since 33.4.0 (but since 28.0 in the JRE flavor)Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 17:49:12 GMT 2025 - 33.2K bytes - Click Count (1) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
* reached the {@linkplain State#RUNNING running} state. * * @param timeout the maximum time to wait * @throws TimeoutException if not all of the services have finished starting within the deadline * @throws IllegalStateException if the service manager reaches a state from which it cannot * become {@linkplain #isHealthy() healthy}.Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 17:49:12 GMT 2025 - 32.9K bytes - Click Count (0)