- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 136 for Next (0.14 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt
throw AssertionError("full event sequence: $fullEventSequence", e) } } inline fun <reified T : CallEvent> removeUpToEvent(): T = removeUpToEvent(T::class.java) /** * Remove and return the next event from the recorded sequence. * * @param eventClass a class to assert that the returned event is an instance of, or null to * take any event class.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9K bytes - Viewed (1) -
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/Dispatcher.kt
val executableCalls = mutableListOf<AsyncCall>() val isRunning: Boolean this.withLock { val i = readyAsyncCalls.iterator() while (i.hasNext()) { val asyncCall = i.next() if (runningAsyncCalls.size >= this.maxRequests) break // Max capacity. if (asyncCall.callsPerHost.get() >= this.maxRequestsPerHost) continue // Host max capacity. i.remove()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K 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/main/kotlin/okhttp3/Cookie.kt
set(Calendar.SECOND, second) set(Calendar.MILLISECOND, 0) return timeInMillis } } /** * Returns the index of the next date character in `input`, or if `invert` the index * of the next non-date character in `input`. */ private fun dateCharacterOffset( input: String, pos: Int, limit: Int, invert: Boolean, ): Int {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:12:05 GMT 2024 - 23.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
if (e is ProtocolException) { return false } // If there was an interruption don't recover, but if there was a timeout connecting to a route // we should try the next route (if there is one). if (e is InterruptedIOException) { return e is SocketTimeoutException && !requestSendStarted }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 12.1K bytes - Viewed (4) -
okhttp-android/src/main/baseline-prof.txt
Lkotlin/sequences/TransformingSequence; Lkotlin/text/CharsKt__CharKt; Lkotlin/text/Charsets; Lkotlin/text/DelimitedRangesSequence; Lkotlin/text/MatchGroup; Lkotlin/text/MatchGroupCollection; Lkotlin/text/MatchResult; Lkotlin/text/MatcherMatchResult$groupValues$1; Lkotlin/text/MatcherMatchResult$groups$1$iterator$1; Lkotlin/text/MatcherMatchResult$groups$1; Lkotlin/text/MatcherMatchResult; Lkotlin/text/Regex;
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Mar 21 11:22:00 GMT 2022 - 127.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
@Throws(IOException::class) fun onReadMessage(text: String) @Throws(IOException::class) fun onReadMessage(bytes: ByteString) fun onReadPing(payload: ByteString) fun onReadPong(payload: ByteString) fun onReadClose( code: Int, reason: String, ) } /** * Process the next protocol frame. *
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/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) -
docs/changelogs/changelog_2x.md
_2015-08-25_ * **Timeouts now default to 10 seconds.** Previously we defaulted to never timing out, and that was a lousy policy. If establishing a connection, reading the next byte from a connection, or writing the next byte to a connection takes more than 10 seconds to complete, you’ll need to adjust the timeouts manually. * **OkHttp now rejects request headers that contain invalid characters.** This
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 26.6K bytes - Viewed (0)