- Sort Score
- Result 10 results
- Languages All
Results 51 - 57 of 57 for handlers (0.44 sec)
-
okhttp/src/test/java/okhttp3/TestLogHandler.kt
private val logs = LinkedBlockingQueue<String>() private val handler = object : Handler() { override fun publish(logRecord: LogRecord) { logs += "${logRecord.level}: ${logRecord.message}" } override fun flush() { } override fun close() { } } private var previousLevel: Level? = null
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/test/java/okhttp3/internal/http2/BaseTestHandler.kt
* limitations under the License. */ package okhttp3.internal.http2 import assertk.fail import okio.BufferedSource import okio.ByteString internal open class BaseTestHandler : Http2Reader.Handler { override fun data( inFinished: Boolean, streamId: Int, source: BufferedSource, length: Int, ) { fail("") } override fun headers( inFinished: Boolean,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
import okio.ForwardingSource import okio.Sink import okio.Source import okio.buffer /** * Transmits a single HTTP request and a response pair. This layers connection management and events * on [ExchangeCodec], which handles the actual I/O. */ class Exchange( internal val call: RealCall, internal val eventListener: EventListener, internal val finder: ExchangeFinder, private val codec: ExchangeCodec, ) {
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
val out = Buffer() Http2Writer(out, true).windowUpdate(expectedStreamId, windowSizeIncrement) return out } private fun assertHeaderBlock(): Http2Reader.Handler { return object : BaseTestHandler() { override fun headers( inFinished: Boolean, streamId: Int, associatedStreamId: Int, headerBlock: List<Header>, ) {
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) -
okhttp/src/main/kotlin/okhttp3/Connection.kt
* one or more streams, and then released. An allocated connection won't be stolen by other calls * while a redirect or authorization challenge is being handled. * * When the maximum concurrent streams limit is reduced, some allocations will be rescinded. * Attempting to create new streams on these allocations will fail. *
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/test/java/okhttp3/RequestCommonTest.kt
assertThat(request.tag<Any>()).isSameAs(objectTag) assertThat(request.tag(Any::class)).isSameAs(objectTag) 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() {
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/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat
service.gov.scot // Scry Security : http://www.scrysec.com // Submitted by Shante Adam <******@****.***> scrysec.com // Securepoint GmbH : https://www.securepoint.de // Submitted by Erik Anders <erik.anders@securepoint.de> firewall-gateway.com firewall-gateway.de my-gateway.de my-router.de spdns.de spdns.eu firewall-gateway.net my-firewall.org myfirewall.org spdns.org
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 240.3K bytes - Viewed (3)