Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for suspend (0.07 sec)

  1. 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)
  2. 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)
  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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jun 19 04:20:30 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  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 Sep 05 11:42:10 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 Sep 05 11:42:10 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: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/job/ExecJobTest.java

            assertSame(execJob, result);
            assertEquals(2, execJob.jvmOptions.size());
            assertEquals("-Xdebug", execJob.jvmOptions.get(0));
            assertEquals("-Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=localhost:8000", execJob.jvmOptions.get(1));
        }
    
        // Test gcLogging method
        public void test_gcLogging() {
            ExecJob result = execJob.gcLogging();
            assertSame(execJob, result);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 24.5K bytes
    - Viewed (0)
  10. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jun 18 21:43:06 UTC 2025
    - 22.8K bytes
    - Viewed (0)
Back to top