- Sort Score
- Result 10 results
- Languages All
Results 31 - 36 of 36 for Mitake (0.2 sec)
-
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 Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 1.5K bytes - Viewed (0) -
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 Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Mar 21 11:22:00 GMT 2022 - 127.9K 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 Apr 26 11:42:10 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 Apr 26 11:42:10 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 Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
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 Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0)