Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 563 for eval (0.02 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt

     */
    class Http2Reader(
      /** Creates a frame reader with max header table size of 4096. */
      private val source: BufferedSource,
      private val client: Boolean,
    ) : Closeable {
      private val continuation: ContinuationSource = ContinuationSource(this.source)
      private val hpackReader: Hpack.Reader =
        Hpack.Reader(
          source = continuation,
          headerTableSizeSetting = 4096,
        )
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 19.8K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/HttpUrlJvmTest.kt

      fun fromUriUnsupportedScheme() {
        val uri = URI("mailto:******@****.***")
        assertThat(uri.toHttpUrlOrNull()).isNull()
      }
    
      @Test
      fun fromUriPartial() {
        val uri = URI("/path")
        assertThat(uri.toHttpUrlOrNull()).isNull()
      }
    
      @Test
      fun toJavaNetUrl() {
        val httpUrl = "http://username:password@host/path?query#fragment".toHttpUrl()
        val javaNetUrl = httpUrl.toUrl()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 12K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

     */
    class TaskQueue internal constructor(
      internal val taskRunner: TaskRunner,
      internal val name: String,
    ) {
      internal var shutdown = false
    
      /** This queue's currently-executing task, or null if none is currently executing. */
      internal var activeTask: Task? = null
    
      /** Scheduled tasks ordered by [Task.nextExecuteNanoTime]. */
      internal val futureTasks = mutableListOf<Task>()
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        address: Address,
        policy: AddressPolicy,
      ) {
        val state = AddressState(address, taskRunner.newQueue(), policy)
        val newConnectionsNeeded: Int
    
        while (true) {
          val oldMap = this.addressStates
          val newMap = oldMap + (address to state)
          if (addressStatesUpdater.compareAndSet(this, oldMap, newMap)) {
            val oldPolicyMinimumConcurrentCalls = oldMap[address]?.policy?.minimumConcurrentCalls ?: 0
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/HeadersJvmTest.kt

        ).isEqualTo(20L)
      }
    
      @Test fun addDate() {
        val expected = Date(0L)
        val headers =
          Headers
            .Builder()
            .add("testDate", expected)
            .build()
        assertThat(headers["testDate"]).isEqualTo("Thu, 01 Jan 1970 00:00:00 GMT")
        assertThat(headers.getDate("testDate")).isEqualTo(Date(0L))
      }
    
      @Test fun addInstant() {
        val expected = Instant.ofEpochMilli(0L)
        val headers =
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:51:25 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt

      projectRoot: Path = ".".toPath(),
      val fileSystem: FileSystem = FileSystem.SYSTEM,
      val client: OkHttpClient = OkHttpClient(),
    ) {
      private val testResources = projectRoot / "okhttp/src/jvmTest/resources"
      private val publicSuffixListDotDat = testResources / "okhttp3/internal/publicsuffix/public_suffix_list.dat"
      private val outputFile = testResources / PUBLIC_SUFFIX_RESOURCE
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Aug 06 05:33:11 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/SequentialExchangeFinder.kt

    internal class SequentialExchangeFinder(
      override val routePlanner: RoutePlanner,
    ) : ExchangeFinder {
      override fun find(): RealConnection {
        var firstException: IOException? = null
        while (true) {
          if (routePlanner.isCanceled()) throw IOException("Canceled")
    
          try {
            val plan = routePlanner.plan()
    
            if (!plan.isReady) {
              val tcpConnectResult = plan.connectTcp()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

    class CacheInterceptor(
      internal val cache: Cache?,
    ) : Interceptor {
      @Throws(IOException::class)
      override fun intercept(chain: Interceptor.Chain): Response {
        val call = chain.call()
        val cacheCandidate = cache?.get(chain.request().requestForCache())
    
        val now = System.currentTimeMillis()
    
        val strategy = CacheStrategy.Factory(now, chain.request(), cacheCandidate).compute()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

          if (isWriter) {
            writerToClose?.closeQuietly()
          }
        }
      }
    
      internal class Message(
        val formatOpcode: Int,
        val data: ByteString,
      )
    
      internal class Close(
        val code: Int,
        val reason: ByteString?,
        val cancelAfterCloseMillis: Long,
      )
    
      private inner class WriterTask : Task("$name writer") {
        override fun runOnce(): Long {
          try {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt

        // We use UTF-8 in the list so we need to convert to Unicode.
        val unicodeDomain = IDN.toUnicode(domain)
        val domainLabels = splitDomain(unicodeDomain)
    
        val rule = findMatchingRule(domainLabels)
        if (domainLabels.size == rule.size && rule[0][0] != EXCEPTION_MARKER) {
          return null // The domain is a public suffix.
        }
    
        val firstLabelOffset =
          if (rule[0][0] == EXCEPTION_MARKER) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 28 07:33:49 UTC 2025
    - 8.5K bytes
    - Viewed (0)
Back to top