- Sort Score
- Num 10 results
- Language All
Results 101 - 110 of 5,460 for until (0.02 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
* the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.Futures.allAsList; import static com.google.common.util.concurrent.Futures.getDone; import static com.google.common.util.concurrent.Futures.immediateVoidFuture; import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 13.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt
* [trailers], this doesn't block if the trailers are not immediately available, and instead * returns null. * * This will typically return null until [ResponseBody.source] has buffered the last byte of the * response body. Call `body.source().request(1024 * 1024)` to block until either that's done, or * 1 MiB of response data is loaded into memory. (You could use any size here, though large values * risk exhausting memory.) *
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Jul 28 14:39:28 GMT 2025 - 18.1K bytes - Click Count (0) -
helm/minio/templates/_helper_create_policy.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
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Mar 21 06:38:06 GMT 2023 - 2K bytes - Click Count (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/Certificates.kt
encodeBase64Lines(encoded.toByteString()) append("-----END CERTIFICATE-----\n") } internal fun StringBuilder.encodeBase64Lines(data: ByteString) { val base64 = data.base64() for (i in 0 until base64.length step 64) { append(base64, i, minOf(i + 64, base64.length)).append('\n') }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 2.8K bytes - Click Count (0) -
build-logic/build-update-utils/src/main/kotlin/gradlebuild/buildutils/tasks/AbstractVersionsUpdateTask.kt
import org.gradle.api.file.RegularFileProperty import org.gradle.api.provider.Property import org.gradle.api.tasks.Internal import org.gradle.internal.util.PropertiesUtils import org.gradle.work.DisableCachingByDefault import org.w3c.dom.Element import java.util.Properties import javax.xml.XMLConstants import javax.xml.parsers.DocumentBuilderFactory @DisableCachingByDefault(because = "Not worth tracking")
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Fri Oct 24 09:10:28 GMT 2025 - 3.4K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/building/ModelSource2.java
* repositories. * <p> * ModelSource2 instances are cached in {@link ModelBuildingRequest#getModelCache()}. Implementations must guarantee * that the connection to the backing store remains active until request's {@link ModelCache} is discarded or flushed. * * @deprecated use {@code org.apache.maven.api.services.ModelBuilder} instead */ @Deprecated(since = "4.0.0") public interface ModelSource2 extends ModelSource {Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Tue Feb 25 08:27:34 GMT 2025 - 2.4K bytes - Click Count (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/InsecureExtendedTrustManager.kt
/** * This extends [X509ExtendedTrustManager] to disable verification for a set of hosts. * * Note that the superclass [X509ExtendedTrustManager] isn't available on Android until version 7 * (API level 24). */ @IgnoreJRERequirement internal class InsecureExtendedTrustManager( private val delegate: X509ExtendedTrustManager, private val insecureHosts: List<String>,
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 2.7K bytes - Click Count (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/PostStreaming.kt
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.9K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/CollectionCreationTester.java
}); } /** * Returns the {@link Method} instance for {@link #testCreateWithNull_unsupported()} so that tests * can suppress it with {@code FeatureSpecificTestSuiteBuilder.suppressing()} until <a * href="https://bugs.openjdk.org/browse/JDK-5045147">JDK-5045147</a> is fixed. */ @J2ktIncompatible @GwtIncompatible // reflection public static Method getCreateWithNullUnsupportedMethod() {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 3K bytes - Click Count (0) -
src/main/java/jcifs/SmbWatchHandle.java
*/ package jcifs; import java.util.List; import java.util.concurrent.Callable; /** * Handle for receiving change notifications from an SMB server * * * @author mbechler * */ public interface SmbWatchHandle extends AutoCloseable, Callable<List<FileNotifyInformation>> { /** * Get the next set of changes *
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 2.3K bytes - Click Count (0)