- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 50 for Hummer (0.24 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
import okhttp3.internal.okHttpName import okhttp3.internal.platform.Platform import okio.IOException class RealConnectionPool( private val taskRunner: TaskRunner, /** * The maximum number of idle connections across all addresses. * Connections needed to satisfy a [ConnectionPool.AddressPolicy] are not considered idle. */ private val maxIdleConnections: Int, keepAliveDuration: Long,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
private val atomicRequestCount = AtomicInteger() /** * The number of HTTP requests received thus far by this server. This may exceed the number of * HTTP connections when connection reuse is in practice. */ 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
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/internal/cache/CacheStrategy.kt
request.newBuilder() .headers(conditionalRequestHeaders.build()) .build() return CacheStrategy(conditionalRequest, cacheResponse) } /** * Returns the number of milliseconds that the response was fresh for, starting from the served * date. */ private fun computeFreshnessLifetime(): Long { val responseCaching = cacheResponse!!.cacheControl
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/src/main/kotlin/okhttp3/EventListener.kt
* upgrade. * * If the response body is closed before the response body is exhausted, this is invoked at the * time it is closed. In such calls [byteCount] is the number of bytes returned to the * application. This may be smaller than the resource's byte count if were read to completion. * * This method is always invoked after [responseBodyStart]. */
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/MediaTypeTest.kt
val mediaType = parse("Message/Partial; number=2; total=3; id=\"oc=******@****.***\"") assertEquals("2", mediaType.parameter("number")) assertEquals("3", mediaType.parameter("total")) assertEquals("oc=******@****.***", mediaType.parameter("id")) assertNull(mediaType.parameter("foo")) } @Test fun testRepeatedParameter() { val mediaType = parse("multipart/mixed; number=2; number=3")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
okhttp-idna-mapping-table/src/main/resources/okhttp3/internal/idna/IdnaMappingTable.txt
246F ; mapped ; 0031 0036 # 1.1 CIRCLED NUMBER SIXTEEN 2470 ; mapped ; 0031 0037 # 1.1 CIRCLED NUMBER SEVENTEEN 2471 ; mapped ; 0031 0038 # 1.1 CIRCLED NUMBER EIGHTEEN 2472 ; mapped ; 0031 0039 # 1.1 CIRCLED NUMBER NINETEEN 2473 ; mapped ; 0032 0030 # 1.1 CIRCLED NUMBER TWENTY
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Feb 10 11:25:47 GMT 2024 - 854.1K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/Connection.kt
* options and then retried without them should the attempt fail. * * ## Connection Reuse * * Each connection can carry a varying number of streams, depending on the underlying protocol being * used. HTTP/1.x connections can carry either zero or one streams. HTTP/2 connections can carry any * number of streams, dynamically configured with `SETTINGS_MAX_CONCURRENT_STREAMS`. A connection
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskLogger.kt
private fun Logger.log( task: Task, queue: TaskQueue, message: String, ) { fine("${queue.name} ${String.format("%-22s", message)}: ${task.name}") } /** * Returns a duration in the nearest whole-number units like "999 µs" or " 1 s ". This rounds 0.5 * units away from 0 and 0.499 towards 0. The smallest unit this returns is "µs"; the largest unit * it returns is "s". For values in [-499..499] this returns " 0 µs". *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
} /** A request body that fires events when it completes. */ private inner class RequestBodySink( delegate: Sink, /** The exact number of bytes to be written, or -1L if that is unknown. */ private val contentLength: Long, ) : ForwardingSink(delegate) { private var completed = false private var bytesReceived = 0L
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.2K bytes - Viewed (2) -
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
frame.writeByte(Http2.TYPE_SETTINGS) frame.writeByte(FLAG_NONE) frame.writeInt(0) // Settings are always on the connection stream 0. frame.writeShort(7) // old number for SETTINGS_INITIAL_WINDOW_SIZE frame.writeInt(1) val settingValue = AtomicInteger() reader.nextFrame( requireSettings = false, object : BaseTestHandler() { override fun settings(
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)