- Sort Score
- Result 10 results
- Languages All
Results 31 - 35 of 35 for TaskRunner (0.04 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskLogger.kt
val loggingEnabled = isLoggable(Level.FINE) if (loggingEnabled) { startNs = queue.taskRunner.backend.nanoTime() log(task, queue, "starting") } var completedNormally = false try { val result = block() completedNormally = true return result } finally { if (loggingEnabled) { val elapsedNs = queue.taskRunner.backend.nanoTime() - startNs if (completedNormally) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // SYN_STREAM. peer.play() val taskRunner = taskFaker.taskRunner val connection = Http2Connection .Builder(true, taskRunner) .socket(peer.openSocket().asBufferedSocket(), "peer") .pushObserver(IGNORE) .build() connection.start(sendConnectionPreface = false) val queues = taskRunner.activeQueues() assertThat(queues).hasSize(1) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 75.5K bytes - Viewed (0) -
okhttp/src/androidMain/baseline-prof.txt
HSPLokhttp3/internal/concurrent/TaskRunner$RealBackend;->nanoTime()J HSPLokhttp3/internal/concurrent/TaskRunner$runnable$1;-><init>(Lokhttp3/internal/concurrent/TaskRunner;)V HSPLokhttp3/internal/concurrent/TaskRunner$runnable$1;->run()V HSPLokhttp3/internal/concurrent/TaskRunner;-><clinit>()V HSPLokhttp3/internal/concurrent/TaskRunner;-><init>(Lokhttp3/internal/concurrent/TaskRunner$Backend;Ljava/util/logging/Logger;I)V
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Dec 30 23:28:56 UTC 2024 - 127.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt
import okhttp3.TestUtil.assumeNotWindows import okhttp3.TestUtil.repeat import okhttp3.WebSocket import okhttp3.WebSocketListener import okhttp3.internal.UnreadableResponseBody import okhttp3.internal.concurrent.TaskRunner import okhttp3.internal.ws.WebSocketProtocol.acceptHeader import okhttp3.testing.Flaky import okhttp3.testing.PlatformRule import okio.Buffer import okio.ByteString import okio.ByteString.Companion.decodeHex
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 35.5K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 18.7K bytes - Viewed (0)