Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for suspend (0.03 sec)

  1. 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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  2. 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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Aug 06 05:33:11 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  3. 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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jun 19 04:20:30 UTC 2025
    - 1.4K bytes
    - Viewed (1)
  4. 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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  5. 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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2K bytes
    - Viewed (0)
  6. 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: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  7. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:45:32 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  8. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:45:32 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/base/Converter.java

      /** Constructor for use by subclasses. */
      protected Converter() {
        this(true);
      }
    
      /** Constructor used only by {@code LegacyConverter} to suspend automatic null-handling. */
      Converter(boolean handleNullAutomatically) {
        this.handleNullAutomatically = handleNullAutomatically;
      }
    
      // SPI methods (what subclasses must implement)
    
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Jun 18 21:43:06 UTC 2025
    - 22.8K bytes
    - Viewed (0)
  10. src/main/resources/fess_config.properties

    -Dlog4j.skipJansi=true\n\
    -Dsun.java2d.cmm=sun.java2d.cmm.kcms.KcmsServiceProvider\n\
    -Dorg.apache.pdfbox.rendering.UsePureJavaCMYKConversion=true\n\
    
    #-Xdebug\n\
    #-Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=127.0.0.1:8000\n\
    
    # job
    
    # System job IDs for scheduled jobs.
    job.system.job.ids=default_crawler
    # Template for web crawler job title.
    job.template.title.web=Web Crawler - {0}
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Dec 11 09:47:03 UTC 2025
    - 54.8K bytes
    - Viewed (0)
Back to top