- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 216 for objects (0.14 sec)
-
okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt
|retry | """.trimMargin(), ) assertThat(callbacks).isEmpty() } private fun consumeEvents(source: String) { val callback: ServerSentEventReader.Callback = object : ServerSentEventReader.Callback { override fun onEvent( id: String?, type: String?, data: String, ) { callbacks.add(Event(id, type, data)) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Authenticator.kt
* application interceptor, such as when implementing client-specific retries. */ @Throws(IOException::class) fun authenticate( route: Route?, response: Response, ): Request? companion object { /** An authenticator that knows no credentials and makes no attempt to authenticate. */ @JvmField val NONE: Authenticator = AuthenticatorNone() private class AuthenticatorNone : Authenticator {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
origin: String, protocol: ByteString, host: String, port: Int, maxAge: Long, ) { throw UnsupportedOperationException() } } companion object { private val logger = Logger.getLogger(MockHttp2Peer::class.java.name) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketWriterTest.kt
} private fun assertData(expected: ByteString) { val actual = data.readByteString(Math.min(expected.size.toLong(), data.size)) assertThat(actual).isEqualTo(expected) } companion object { private fun binaryData(length: Int): ByteString { val junk = ByteArray(length) Random(0).nextBytes(junk) return junk.toByteString() } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Huffman.kt
* * * `com.twitter.hpack.HuffmanEncoder` * * `com.twitter.hpack.HuffmanDecoder` * * `com.twitter.hpack.HpackUtil` * * [twitter_hpack]: https://github.com/twitter/hpack */ object Huffman { // Appendix C: Huffman Codes // http://tools.ietf.org/html/draft-ietf-httpbis-header-compression-12#appendix-B private val CODES = intArrayOf(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/idn/Punycode.kt
* * [RFC 3492]: https://datatracker.ietf.org/doc/html/rfc3492 * [RFC 5890]: https://datatracker.ietf.org/doc/html/rfc5890 * [UTS #46]: https://www.unicode.org/reports/tr46/ */ object Punycode { val PREFIX_STRING = "xn--" val PREFIX = PREFIX_STRING.encodeUtf8() private const val BASE = 36 private const val TMIN = 1 private const val TMAX = 26 private const val SKEW = 38
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 03:04:50 GMT 2024 - 8.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
sourceCount-- if (sourceCount == 0) { fileToClose = file file = null } } fileToClose?.closeQuietly() } } companion object { // TODO(jwilson): what to do about timeouts? They could be different and unfortunately when any // timeout is hit we like to tear down the whole stream. private const val SOURCE_UPSTREAM = 1
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
private val connectionPool: RealConnectionPool = client.connectionPool.delegate internal val eventListener: EventListener = client.eventListenerFactory.create(this) private val timeout = object : AsyncTimeout() { override fun timedOut() { ******@****.***() } }.apply { timeout(client.callTimeoutMillis.toLong(), MILLISECONDS) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/test/java/okhttp3/HttpUrlTest.kt
assertThat(parse("http://username:@host/path")) .isEqualTo(parse("http://username@host/path")) } @Test fun passwordWithEmptyUsername() { // Chrome doesn't mind, but Firefox rejects URLs with empty usernames and non-empty passwords. assertThat(parse("http://:@host/path")) .isEqualTo(parse("http://host/path")) assertThat(parse("http://:password@@host/path").encodedPassword)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 67.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Response.kt
* * Use the `request` of the [networkResponse] field to get the wire-level request that was * transmitted. In the case of follow-ups and redirects, also look at the `request` of the * [priorResponse] objects, which have its own [priorResponse]. */ @get:JvmName("request") val request: Request, /** Returns the HTTP protocol, such as [Protocol.HTTP_1_1] or [Protocol.HTTP_1_0]. */ @get:JvmName("protocol") val protocol: Protocol,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 15.5K bytes - Viewed (0)