- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 54 for nextUp (0.15 sec)
-
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/Case.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Dec 23 10:26:25 GMT 2023 - 1.3K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt
* a CountdownLatch). */ @Throws(InterruptedException::class) abstract fun dispatch(request: RecordedRequest): MockResponse /** * Returns an early guess of the next response, used for policy on how an incoming request should * be received. The default implementation returns an empty response. Mischievous implementations
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.7K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
private var peekedHeader: DerHeader? = null private val bytesLeft: Long get() = if (limit == -1L) -1L else (limit - byteCount) fun hasNext(): Boolean = peekHeader() != null /** * Returns the next header to process unless this scope is exhausted. * * This returns null if: * * * The stream is exhausted. * * We've read all of the bytes of an object whose length is known.
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) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
val openClientSocket = openClientSockets.iterator() while (openClientSocket.hasNext()) { openClientSocket.next().closeQuietly() openClientSocket.remove() } val httpConnection = openConnections.iterator() while (httpConnection.hasNext()) { httpConnection.next().closeQuietly() httpConnection.remove() } dispatcher.shutdown() } }
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/connection/RealConnectionPool.kt
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) -
okhttp/src/test/java/okhttp3/CacheTest.kt
assertThat(i.next()).isEqualTo(urlA.toString()) assertThat(i.hasNext()).isTrue() assertThat(i.next()).isEqualTo(urlB.toString()) assertThat(i.hasNext()).isTrue() assertThat(i.next()).isEqualTo(urlC.toString()) // ... and nothing else. assertThat(i.hasNext()).isFalse() assertFailsWith<NoSuchElementException> { i.next() } } @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 108.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
fun onReadPing(payload: ByteString) fun onReadPong(payload: ByteString) fun onReadClose( code: Int, reason: String, ) } /** * Process the next protocol frame. * * * If it is a control frame this will result in a single call to [FrameCallback]. * * If it is a message frame this will result in a single call to [FrameCallback.onReadMessage].
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/idn/IdnaMappingTable.kt
* 125 : Mapped inline to the sequence: [b2a, b3]. * 126 : Mapped inline to the sequence: [b2, b3a]. * 127 : Mapped inline to the sequence: [b2a, b3a]. * * The range goes until the beginning of the next range. * * When b2 and b3 are unused, their values are set to 0x2d ('-'). * * Section Index (1,240 bytes) * =========================== *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Apr 02 11:39:58 GMT 2024 - 9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt
if (labels[currentLabelIndex].size == currentLabelByteIndex) { // We've exhausted our current label. Either there are more labels to compare, in which // case we expect a dot as the next character. Otherwise, we've checked all our labels. if (currentLabelIndex == labels.size - 1) { break } else { currentLabelIndex++
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/tls/CertificatePinnerChainValidationTest.kt
.build(), ) val response1 = call1.execute() assertThat(response1.body.string()).isEqualTo("abc") response1.close() // Force a fresh connection for the next request. client.connectionPool.evictAll() // Confirm that a second request also succeeds. This should detect caching problems. server.enqueue( MockResponse.Builder() .body("def")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 23.8K bytes - Viewed (0)