- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for Mitake (0.15 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
override fun peek(): T = error("unsupported") override fun offer( element: T, timeout: Long, unit: TimeUnit, ) = error("unsupported") override fun take() = error("unsupported") override fun remainingCapacity() = error("unsupported") override fun drainTo(sink: MutableCollection<in T>) = error("unsupported") override fun drainTo(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
webSocket: WebSocket, t: Throwable, response: Response?, ) { throw e } }, ) newWebSocket() assertThat(testLogHandler.take()).isEqualTo("INFO: [WS client] onFailure") } @Test fun throwingOnMessageClosesImmediatelyAndFails() { webServer.enqueue( MockResponse.Builder() .webSocketUpgrade(serverListener)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
@Throws(IOException::class) abstract fun onStream(stream: Http2Stream) /** * Notification that the connection's peer's settings may have changed to [settings]. * Implementations should take appropriate action to handle the updated settings. * * Methods to this method may be made concurrently with [onStream]. But a calls to this method * are serialized. */ open fun onSettings(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
* forever. * * @return the head of the request queue */ @Throws(InterruptedException::class) fun takeRequest(): RecordedRequest = requestQueue.take() /** * Awaits the next HTTP request (waiting up to the specified wait time if necessary), removes it, * and returns it. Callers should use this to verify the request was sent as intended within the
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/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
} taskFaker.runTasks() assertEvents( "take plan 0", "plan 0 TCP connecting...", ) taskFaker.advanceUntil(250.ms) assertEvents( "take plan 1", "plan 1 TCP connecting...", ) taskFaker.advanceUntil(500.ms) assertEvents( "take plan 2", "plan 0 cancel", "plan 1 cancel", )
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 20.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
"FINE: Q10000 scheduled after 100 µs: task one", "FINE: Q10000 scheduled after 200 µs: task two", ) } /** * We don't track the active task in scheduled tasks. This behavior might be a mistake, but it's * cumbersome to implement properly because the active task might be a cancel. */ @Test fun scheduledTasksDoesNotIncludeRunningTask() { val task = object : Task("task one") {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 23K bytes - Viewed (0)