- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 516 for Until (0.13 sec)
-
guava/src/com/google/common/collect/FluentIterable.java
/** * Returns a fluent iterable that combines two iterables. The returned iterable has an iterator * that traverses the elements in {@code a}, followed by the elements in {@code b}. The source * iterators are not polled until necessary. * * <p>The returned iterable's iterator supports {@code remove()} when the corresponding input * iterator supports it. * * <p><b>{@code Stream} equivalent:</b> {@link Stream#concat}. *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 18:35:44 UTC 2025 - 34.7K bytes - Viewed (0) -
build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild.detekt.gradle.kts
* limitations under the License. */ plugins { id("io.gitlab.arturbosch.detekt") } detekt { // enable all default rules buildUponDefaultConfig = true // customize some of the rules, until we can fix the offending cases config.convention(project.isolated.rootProject.projectDirectory.file("gradle/detekt.yml")) // also check the project build file source.from(project.buildFile) }Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Thu Jun 20 10:11:35 UTC 2024 - 1.1K bytes - Viewed (0) -
internal/once/singleton.go
package once // Singleton contains a pointer to T that must be set once. // Until the value is set all Get() calls will block. type Singleton[T any] struct { v *T set chan struct{} } // NewSingleton creates a new unset singleton. func NewSingleton[T any]() *Singleton[T] { return &Singleton[T]{set: make(chan struct{}), v: nil} } // Get will return the singleton value. func (s *Singleton[T]) Get() *T { <-s.set return s.v
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 952 bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/idn/IdnaMappingTableTest.kt
val rangesOffsets = mutableListOf<Int>() for (i in 0 until compactTable.sections.length step 4) { rangesIndices += compactTable.sections.read14BitInt(i) rangesOffsets += compactTable.sections.read14BitInt(i + 2) } assertThat(rangesIndices).isEqualTo(rangesIndices.sorted()) // Check the ranges. for (r in 0 until rangesOffsets.size) { val rangePos = rangesOffsets[r] * 4
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 8.9K bytes - Viewed (0) -
.github/dependabot.yml
version: 2 updates: # TODO(b/170636568): Enable Maven updates? Perhaps wait until we can more # easily import the generated PRs into our internal repo. # - package-ecosystem: "maven" # directory: "/" # schedule: # interval: "weekly" # groups: # dependencies: # applies-to: version-updates # patterns: # - "*" # - package-ecosystem: "maven" # directory: "/android" # schedule:
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Mar 21 21:15:53 UTC 2025 - 762 bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
// TODO(user): Consider scaling by number of mutator threads, // e.g. using Thread#activeCount() return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L)); } /** * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector * as necessary to try to ensure that this will happen. * * @throws RuntimeException if timed out or interrupted while waiting */
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 11.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-HostnamesCommon.kt
when { isMappedIpv4Address(address) -> address.sliceArray(12 until 16) else -> address } /** Returns true for IPv6 addresses like `0000:0000:0000:0000:0000:ffff:XXXX:XXXX`. */ private fun isMappedIpv4Address(address: ByteArray): Boolean { if (address.size != 16) return false for (i in 0 until 10) { if (address[i] != 0.toByte()) return false }Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 11.2K bytes - Viewed (0) -
docs/contribute/concurrency.md
application-layer must block on writing I/O. We can't return from a write until we've pushed its bytes onto the socket. Otherwise, if the write fails we are unable to deliver its IOException to the application. We would have told the application layer that the write succeeded, but it didn't! The application-layer can also do blocking reads. If the application asks to read and there's nothing available, we need to hold that thread until either the bytes arrive, the stream is closed, or a timeout elapses....
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/idn/Punycode.kt
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 8.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Headers.kt
/** Returns an immutable case-insensitive set of header names. */ fun names(): Set<String> { val result = TreeSet(String.CASE_INSENSITIVE_ORDER) for (i in 0 until size) { result.add(name(i)) } return result.unmodifiable() } /** Returns an immutable list of the header values for `name`. */ fun values(name: String): List<String> = commonValues(name)
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue May 27 14:51:25 UTC 2025 - 11.5K bytes - Viewed (0)