- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 563 for eval (0.02 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)