- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 45 for suspend (0.05 sec)
-
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(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.7K bytes - Viewed (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) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Aug 06 05:33:11 UTC 2025 - 6.1K bytes - Viewed (0) -
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()Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3.5K bytes - Viewed (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 {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jun 19 04:20:30 UTC 2025 - 1.4K bytes - Viewed (1) -
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 =Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 2K bytes - Viewed (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" # -----------------------------------------------------------------------------
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Thu Jul 24 09:49:07 UTC 2025 - 7.7K bytes - Viewed (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
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 46.8K bytes - Viewed (0) -
docs/resiliency/resiliency-tests.sh
echo echo -e "${GREEN}Running test_resiliency_failure_with_server_down_and_single_disk_offline ...${NC}" # Stop one node docker stop resiliency-minio1-1 # In additional, suspend one more disk per set in order to induce a failure docker exec resiliency-minio2-1 /bin/sh -c "mv /data2/.minio.sys /data2/.minio.bkp && touch /data2/.minio.sys"Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sat Dec 21 04:24:45 UTC 2024 - 20.5K bytes - Viewed (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
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 12K bytes - Viewed (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. *Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 14.2K bytes - Viewed (0)