- Sort Score
- Num 10 results
- Language All
Results 101 - 110 of 4,361 for until (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava-tests/test/com/google/common/eventbus/AsyncEventBusTest.java
* limitations under the License. */ package com.google.common.eventbus; import static com.google.common.truth.Truth.assertWithMessage; import java.util.ArrayList; import java.util.List; import java.util.concurrent.Executor; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /** * Test case for {@link AsyncEventBus}. * * @author Cliff Biffle */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 2.4K bytes - Click Count (0) -
internal/http/lambda-headers.go
AmzFwdHeaderObjectLockLegalHold = "x-amz-fwd-header-x-amz-object-lock-legal-hold" AmzFwdHeaderObjectLockRetainUntil = "x-amz-fwd-header-x-amz-object-lock-retain-until-date" AmzFwdHeaderMPPartsCount = "x-amz-fwd-header-x-amz-mp-parts-count" AmzFwdHeaderReplicationStatus = "x-amz-fwd-header-x-amz-replication-status"
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 3.1K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/ListListIteratorTester.java
import com.google.common.collect.testing.features.CollectionFeature; import com.google.common.collect.testing.features.ListFeature; import java.lang.reflect.Method; import java.util.List; import java.util.ListIterator; import java.util.Set; import java.util.concurrent.CopyOnWriteArraySet; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; import org.junit.Ignore; /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt
*/ package okhttp3.internal.ws import java.io.IOException import java.net.ProtocolException import java.net.SocketTimeoutException import java.util.ArrayDeque import java.util.Random import java.util.concurrent.TimeUnit import java.util.concurrent.TimeUnit.MILLISECONDS import okhttp3.Call import okhttp3.Callback import okhttp3.EventListener import okhttp3.OkHttpClient import okhttp3.Protocol
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 21.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/FormBody.kt
*/ private fun writeOrCountBytes( sink: BufferedSink?, countBytes: Boolean, ): Long { var byteCount = 0L val buffer: Buffer = if (countBytes) Buffer() else sink!!.buffer for (i in 0 until encodedNames.size) { if (i > 0) buffer.writeByte('&'.code) buffer.writeUtf8(encodedNames[i]) buffer.writeByte('='.code) buffer.writeUtf8(encodedValues[i]) } if (countBytes) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 4.3K bytes - Click Count (0) -
helm/minio/templates/_helper_create_bucket.txt
echo "Connecting to MinIO server: $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT" MC_COMMAND="${MC} alias set myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET" $MC_COMMAND STATUS=$? until [ $STATUS = 0 ]; do ATTEMPTS=$(expr $ATTEMPTS + 1) echo \"Failed attempts: $ATTEMPTS\" if [ $ATTEMPTS -gt $LIMIT ]; then exit 1 fi sleep 2 # 1 second intervals between attempts $MC_COMMAND
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 07 09:47:02 GMT 2025 - 3.5K bytes - Click Count (0) -
buildscripts/minio-upgrade.sh
echo "mismatch - expected ${expected}, got ${got}" exit 1 fi echo "matches - ${expected}, got ${got}" } add_alias() { for i in $(seq 1 4); do echo "... attempting to add alias $i" until (mc alias set minio http://127.0.0.1:9000 minioadmin minioadmin); do echo "...waiting... for 5secs" && sleep 5 done done echo "Sleeping for nginx" sleep 20 } __init__() { sudo apt install curl -y
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Apr 21 16:24:31 GMT 2025 - 2.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
private fun combine( cachedHeaders: Headers, networkHeaders: Headers, ): Headers { val result = Headers.Builder() for (index in 0 until cachedHeaders.size) { val fieldName = cachedHeaders.name(index) val value = cachedHeaders.value(index) if ("Warning".equals(fieldName, ignoreCase = true) && value.startsWith("1")) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Jan 11 12:06:21 GMT 2026 - 10.3K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/cache/LoadingCacheSingleThreadBenchmark.java
import com.google.caliper.AfterExperiment; import com.google.caliper.BeforeExperiment; import com.google.caliper.Benchmark; import com.google.caliper.Param; import com.google.common.primitives.Ints; import java.util.Random; import java.util.concurrent.atomic.AtomicLong; import org.jspecify.annotations.NullUnmarked; /** * Single-threaded benchmark for {@link LoadingCache}. * * @author Charles Fry */ @NullUnmarkedCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 3.4K bytes - Click Count (0) -
android/guava/src/com/google/common/io/ReaderInputStream.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Apr 14 16:36:11 GMT 2025 - 9.3K bytes - Click Count (0)