- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 54 for Vong (0.13 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheStrategy.kt
} var minFreshMillis: Long = 0 if (requestCaching.minFreshSeconds != -1) { minFreshMillis = SECONDS.toMillis(requestCaching.minFreshSeconds.toLong()) } var maxStaleMillis: Long = 0 if (!responseCaching.mustRevalidate && requestCaching.maxStaleSeconds != -1) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 12K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
private class CountingSource(source: Source) : ForwardingSource(source) { var bytesRead = 0L override fun read( sink: Buffer, byteCount: Long, ): Long { val result = delegate.read(sink, byteCount) if (result == -1L) return -1L bytesRead += result return result } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
* entry's sequence number. */ private var nextSequenceNumber: Long = 0 private val cleanupQueue = taskRunner.newQueue() private val cleanupTask = object : Task("$okHttpName Cache") { override fun runOnce(): Long { synchronized(this@DiskLruCache) { if (!initialized || closed) { return -1L // Nothing to do.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
*/ val requestCount: Int get() = atomicRequestCount.get() /** The number of bytes of the POST body to keep in memory to the given limit. */ var bodyLimit: Long = Long.MAX_VALUE var serverSocketFactory: ServerSocketFactory? = null @Synchronized get() { if (field == null && started) { field = ServerSocketFactory.getDefault() // Build the default value lazily.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/EventListener.kt
} /** * Invoked immediately after sending a request body. * * This method is always invoked after [requestBodyStart]. */ open fun requestBodyEnd( call: Call, byteCount: Long, ) { } /** * Invoked when a request fails to be written. * * This method is invoked after [requestHeadersStart] or [requestBodyStart]. Note that request
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
Request.Builder() .url(server.url("/")) .post(AsyncRequestBody()) .build() val call = client.newCall(request) call.timeout() .timeout(500, TimeUnit.MILLISECONDS) // Long enough for the first TLS handshake. call.execute().use { response -> val requestBody = (call.request().body as AsyncRequestBody?)!!.takeSink() val responseBody = response.body.source()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 23.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
val task = object : Task("task") { val schedules = mutableListOf(50.µs) val delays = mutableListOf(200.µs, -1) override fun runOnce(): Long { log += "run@${taskFaker.nanoTime}" if (schedules.isNotEmpty()) { redQueue.schedule(this, schedules.removeAt(0)) } return delays.removeAt(0) } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 23K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RequestCommonTest.kt
assertThat(request.tag(String::class)).isSameAs(stringTag) // TODO check for Jvm or handle Long/long correctly // assertThat(request.tag(Long::class)).isSameAs(longTag) } /** Confirm that we don't accidentally share the backing map between objects. */ @Test fun tagsAreImmutable() { val builder = Request.Builder() .url("https://square.com")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
}.also { expected -> assertThat(expected.message).isEqualTo("FRAME_SIZE_ERROR length > 16384: 16777216") } } @Test fun windowUpdateRoundTrip() { val expectedWindowSizeIncrement: Long = 0x7fffffff writeMedium(frame, 4) // length frame.writeByte(Http2.TYPE_WINDOW_UPDATE) frame.writeByte(FLAG_NONE) frame.writeInt(expectedStreamId) frame.writeInt(expectedWindowSizeIncrement.toInt())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 28.1K bytes - Viewed (0)