- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 47 for suspend (0.25 seconds)
-
samples/tlssurvey/src/main/kotlin/okhttp3/survey/ssllabs/SslLabsClient.kt
private val sslLabsApi = retrofit.create(SslLabsApi::class.java) suspend fun clients(): List<Client> = sslLabsApi.clients().map { userAgent -> Client( userAgent = userAgent.name, version = userAgent.version, platform = userAgent.platform, enabled = userAgent.suiteNames.map { SuiteId(null, it) }, ) } } suspend fun main() { val sslLabsClient = SslLabsClient(
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 1.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt
val request = Request("https://publicsuffix.org/list/public_suffix_list.dat".toHttpUrl()) suspend fun import() { check(fileSystem.metadata(testResources).isDirectory) updateLocalFile() val importResults = readImportResults() writeOutputFile(importResults) } private suspend fun updateLocalFile() = withContext(Dispatchers.IO) {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Aug 06 05:33:11 GMT 2025 - 6.1K bytes - Click Count (0) -
okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt
import kotlinx.coroutines.suspendCancellableCoroutine import okhttp3.Call import okhttp3.Callback import okhttp3.Response import okhttp3.internal.closeQuietly import okio.IOException suspend fun Call.executeAsync(): Response = suspendCancellableCoroutine { continuation -> continuation.invokeOnCancellation { this.cancel() } this.enqueue( object : Callback {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jun 19 04:20:30 GMT 2025 - 1.4K bytes - Click Count (1) -
samples/tlssurvey/src/main/kotlin/okhttp3/survey/RunSurvey.kt
import okhttp3.survey.types.Client import okhttp3.survey.types.SuiteId import okio.FileSystem import okio.Path.Companion.toPath import org.conscrypt.Conscrypt @Suppress("ktlint:standard:property-naming") suspend fun main() { val includeConscrypt = false val client = OkHttpClient .Builder() .cache(Cache(FileSystem.SYSTEM, "build/okhttp_cache".toPath(), 100_000_000)) .build()Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 3.5K bytes - Click Count (0) -
helm/minio/templates/_helper_create_bucket.txt
if [ $VERSIONING = true ]; then echo "Enabling versioning for '$BUCKET'" ${MC} version enable myminio/$BUCKET elif [ $VERSIONING = false ]; then echo "Suspending versioning for '$BUCKET'" ${MC} version suspend myminio/$BUCKET fi else echo "No versioning action for '$BUCKET'" fi else echo "Bucket '$BUCKET' versioning unchanged." fi
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 07 09:47:02 GMT 2025 - 3.5K bytes - Click Count (0) -
samples/tlssurvey/src/main/kotlin/okhttp3/survey/Iana.kt
) { fun fromJavaName(javaName: String): SuiteId = suites.firstOrNull { it.name == javaName || it.name == "TLS_${javaName.drop(4)}" } ?: throw IllegalArgumentException("No such suite: $javaName") } suspend fun fetchIanaSuites(okHttpClient: OkHttpClient): IanaSuites { val url = "https://www.iana.org/assignments/tls-parameters/tls-parameters-4.csv" val call = okHttpClient.newCall(Request(url.toHttpUrl())) val suites =Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 2K bytes - Click Count (0) -
apache-maven/src/assembly/maven/bin/mvn
# MAVEN_SKIP_RC (Optional) Flag to disable loading of mavenrc files. # MAVEN_DEBUG_OPTS (Optional) Specify the debug options to use. Default value is "-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=${MAVEN_DEBUG_ADDRESS}" when --debug is used # MAVEN_DEBUG_ADDRESS (Optional) Set the debug address. Default value is "localhost:8000" # -----------------------------------------------------------------------------
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Dec 10 16:40:06 GMT 2025 - 9.2K bytes - Click Count (0) -
docs/bucket/versioning/README.md
<VersioningConfiguration xmlns="http://s3.amazonaws.com/doc/2006-03-01/"> <Status>Enabled</Status> </VersioningConfiguration> ``` Similarly to suspend versioning set the configuration with Status set to `Suspended`. ``` <VersioningConfiguration xmlns="http://s3.amazonaws.com/doc/2006-03-01/"> <Status>Suspended</Status> </VersioningConfiguration> ``` ## MinIO extension to Bucket Versioning ### Idempotent versions on directory objects
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 12K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/ExecJob.java
* * @return this ExecJob instance for method chaining */ public ExecJob remoteDebug() { return jvmOptions("-Xdebug", "-Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=localhost:8000"); } /** * Enables garbage collection logging for this job execution. * Configures JVM options for comprehensive GC logging with rotation. *Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 14.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
thread.setPriority(Thread.MAX_PRIORITY); Thread.class.getMethod("resume").invoke(thread); thread.join(); // It's possible to race and suspend the thread just before the park call actually takes effect, // causing the thread to be suspended for 3.5 seconds, and then park itself for 2 seconds after // being resumed. To avoid a flake in this scenario, calculate how long that thread actually
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:45:32 GMT 2025 - 46.8K bytes - Click Count (0)