- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 53 for Staken (0.15 sec)
-
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/HttpUrl.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 63.5K bytes - Viewed (1) -
okhttp-android/src/main/baseline-prof.txt
HSPLokio/SegmentPool;-><clinit>()V HSPLokio/SegmentPool;-><init>()V HSPLokio/SegmentPool;->firstRef()Ljava/util/concurrent/atomic/AtomicReference; HSPLokio/SegmentPool;->recycle(Lokio/Segment;)V HSPLokio/SegmentPool;->take()Lokio/Segment; HSPLokio/SocketAsyncTimeout;-><init>(Ljava/net/Socket;)V HSPLokio/Timeout$Companion$NONE$1;-><init>()V HSPLokio/Timeout;-><clinit>()V HSPLokio/Timeout;-><init>()V HSPLokio/Timeout;->throwIfReached()V
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-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt
* * @param eventClass a class to assert that the returned event is an instance of, or null to * take any event class. * @param elapsedMs the time in milliseconds elapsed since the immediately-preceding event, or * -1L to take any duration. */ fun takeEvent( eventClass: Class<out CallEvent>? = null, elapsedMs: Long = -1L, ): CallEvent {
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) -
samples/guide/src/test/kotlin/okhttp3/AllMainsTest.kt
className: String, cause: Throwable, ): Boolean { return when (className) { "okhttp3.recipes.CheckHandshake" -> true // by design "okhttp3.recipes.RequestBodyCompression" -> true // expired token else -> false } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/duplex/AsyncRequestBody.kt
} override fun isDuplex(): Boolean = true @Throws(InterruptedException::class) fun takeSink(): BufferedSink { return requestBodySinks.poll(5, SECONDS) ?: throw AssertionError("no sink to take") } fun assertNoMoreSinks() { assertTrue(requestBodySinks.isEmpty()) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/android/AndroidLog.kt
// We need to handle long logger names before they hit Log. // java.lang.IllegalArgumentException: Log tag "okhttp3.mockwebserver.MockWebServer" exceeds limit of 23 characters return knownLoggers[loggerName] ?: loggerName.take(23) } fun enable() { for ((logger, tag) in knownLoggers) { enableLogging(logger, tag) } } private fun enableLogging( logger: String, tag: String, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.9K bytes - Viewed (0) -
samples/crawler/src/main/java/okhttp3/sample/Crawler.java
} catch (Exception e) { e.printStackTrace(); } }); } executor.shutdown(); } private void drainQueue() throws Exception { for (HttpUrl url; (url = queue.take()) != null; ) { if (!fetchedUrls.add(url)) { continue; } Thread currentThread = Thread.currentThread(); String originalName = currentThread.getName();
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Aug 12 07:26:27 GMT 2021 - 4.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
require(nextPlanIndex < plans.size) { "not enough plans! call addPlan() or set autoGeneratePlans=true in the test to set this up" } val result = plans[nextPlanIndex++] events += "take plan ${result.id}" if (result.yieldBeforePlanReturns) { taskFaker.yield() } val planningThrowable = result.planningThrowable if (planningThrowable != null) throw planningThrowable
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cookie.kt
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)