- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 62 for Gill (0.18 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
import okio.IOException import org.junit.jupiter.api.Assertions open class RecordingConnectionListener( /** * An override to ignore the normal order that is enforced. * EventListeners added by Interceptors will not see all events. */ private val enforceOrder: Boolean = true, ) : ConnectionListener() { val eventSequence: Deque<ConnectionEvent> = ConcurrentLinkedDeque() private val forbiddenLocks = mutableSetOf<Any>()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt
* in practice. To simplify the implementation, we've avoided implementing the flexible rules in * favor of supporting what's actually used in practice. That means if these assertions ever fail, * the implementation will need to be revisited to support a more flexible rule. */ private fun assertWildcardRule(rule: String) { check(rule.startsWith(WILDCARD_CHAR)) { """Wildcard Assertion Failure: '$rule'
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
fun sendFrame(): Http2Writer { outFrames.add(OutFrame(frameCount++, bytesOut.size, false)) return writer } /** * Shortens the last frame from its original length to `length`. This will cause the peer to * close the socket as soon as this frame has been written; otherwise the peer stays open until * explicitly closed. */ fun truncateLastFrame(length: Int): Http2Writer {
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/main/kotlin/okhttp3/internal/http2/Huffman.kt
children[childIndex] = child } node = child } val shift = 8 - accumulatorBitCount val start = (code shl shift) and 0xff val end = 1 shl shift node.children!!.fill(terminal, start, start + end) } private class Node { /** Null if terminal. */ val children: Array<Node?>? /** Terminal nodes have a symbol. */ val symbol: Int
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
private const val INITIAL_BIAS = 72 private const val INITIAL_N = 0x80 /** * Returns null if any label is oversized so much that the encoder cannot encode it without * integer overflow. This will not return null for labels that fit within the DNS size * limits. */ fun encode(string: String): String? { var pos = 0 val limit = string.length val result = Buffer() while (pos < limit) {
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/http2/Settings.kt
const val MAX_CONCURRENT_STREAMS = 4 /** HTTP/2: Size in bytes of the largest frame payload the sender will accept. */ const val MAX_FRAME_SIZE = 5 /** HTTP/2: Advisory only. Size in bytes of the largest header list the sender will accept. */ const val MAX_HEADER_LIST_SIZE = 6 /** Window size in bytes. */ const val INITIAL_WINDOW_SIZE = 7
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.8K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
object DisconnectDuringResponseBody : SocketPolicy /** * Process the response without even attempting to reading the request body. For HTTP/2 this will * send [http2ErrorCode] after the response body or trailers. For HTTP/1 this will close the * socket after the response body or trailers. */ class DoNotReadRequestBody( val http2ErrorCode: Int = 0, ) : SocketPolicy
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketExtensions.kt
* client_max_window_bits="15"; server_no_context_takeover; client_no_context_takeover * ``` * * If any other extension or parameter is specified, then [unknownValues] will be true. Such * responses should be refused as their web socket extensions will not be understood. * * Note that [java.util.zip.Deflater] is hardcoded to use 15 bits (32 KiB) for
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
return insertAt == 0 } /** * Schedules immediate execution of [Task.tryCancel] on all currently-enqueued tasks. These calls * will not be made until any currently-executing task has completed. Tasks that return true will * be removed from the execution schedule. */ fun cancelAll() { lock.assertNotHeld() taskRunner.lock.withLock { if (cancelAllAndDecide()) {
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-sse/src/test/java/okhttp3/sse/internal/EventSourcesHttpTest.kt
""" |data: hey | | """.trimMargin(), ).setHeader("content-type", "text/event-stream") .build(), ) listener.enqueueCancel() // Will cancel in onOpen(). val request = Request.Builder() .url(server.url("/")) .build() val response = client.newCall(request).execute() processResponse(response, listener)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 2.6K bytes - Viewed (0)