- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 39 for isIdle (0.16 sec)
-
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
set("b", "b", "b") while (taskFaker.isIdle()) { assertValue("a", "a", "a") assertValue("b", "b", "b") } } @ParameterizedTest @ArgumentsSource(FileSystemParamProvider::class) fun rebuildJournalOnRepeatedEdits(parameters: Pair<FileSystem, Boolean>) { setUp(parameters.first, parameters.second) while (taskFaker.isIdle()) { set("a", "a", "a") set("b", "b", "b")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
sink: MutableCollection<in T>, maxElements: Int, ) = error("unsupported") } /** Returns true if no tasks have been scheduled. This runs the coordinator for confirmation. */ fun isIdle() = taskRunner.activeQueues().isEmpty() override fun close() { tasksExecutor.shutdownNow() } companion object { var instance = 0 @JvmField
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) -
build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild/testcleanup/TestFilesCleanupService.kt
reports.filter { it.isFile && it.toPath().startsWith(projectBuildDirPath) } .map { projectBuildDirPath.relativize(it.toPath()).toString() to it } .apply { zip(rootBuildDir.resolve("report$projectPathName.zip"), this) } reports.filter { it.isFile && !it.toPath().startsWith(projectBuildDirPath) } .forEach { report ->
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Fri Jul 28 16:19:47 GMT 2023 - 12.5K bytes - Viewed (0) -
build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AbstractBinaryCompatibilityTest.kt
} println(buildResult.output) val richReportFile = inputBuildDir.resolve("binary-compatibility/build/japi/japi.html").apply { assertTrue("Rich report file doesn't exist", isFile) } return CheckResult(failure, scrapeRichReport(richReportFile), buildResult).apply { println(richReport.toText()) block() } } /**
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Mon Sep 25 13:49:37 GMT 2023 - 16.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
} @Test fun idleCallbackInvokedWhenIdle() { val idle = AtomicBoolean() dispatcher.idleCallback = Runnable { idle.set(true) } client.newCall(newRequest("http://a/1")).enqueue(callback) client.newCall(newRequest("http://a/2")).enqueue(callback) executor.finishJob("http://a/1") assertThat(idle.get()).isFalse() val ready = CountDownLatch(1) val proceed = CountDownLatch(1)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
// Connections are replaced if they idle out or are evicted from the pool evictAllConnections(pool) assertThat(pool.connectionCount()).isEqualTo(2) forceConnectionsToExpire(pool, expireTime) assertThat(pool.connectionCount()).isEqualTo(2) // Excess connections aren't removed until they idle out, even if no longer needed
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
samples/guide/src/test/kotlin/okhttp3/AllMainsTest.kt
"$prefix/samples/guide/src/main/java/okhttp3/recipes", "$prefix/samples/guide/src/main/java/okhttp3/recipes/kt", ).map { File(it) } return directories.flatMap { it.listFiles().orEmpty().filter { f -> f.isFile }.toList() } } internal class MainTestProvider : SimpleProvider() { override fun arguments(): List<Any> { val mainFiles = mainFiles() return mainFiles.map {
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) -
build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/sources/SourcesRepository.kt
*/ fun sourceFileAndSourceRootFor(sourceFilePath: String): Pair<File, File> = sourceRoots.asSequence() .map { it.resolve(sourceFilePath) to it } .firstOrNull { it.first.isFile } ?: throw IllegalStateException("Source file '$sourceFilePath' not found, searched in source roots:\n - ${sourceRoots.joinToString("\n - ")}") private val KtFile.normalizedPath: String?
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Mon Feb 20 16:37:41 GMT 2023 - 4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
} /** * A callback to be invoked each time the dispatcher becomes idle (when the number of running * calls returns to zero). * * Note: The time at which a [call][Call] is considered idle is different depending on whether it * was run [asynchronously][Call.enqueue] or [synchronously][Call.execute]. Asynchronous calls * become idle after the [onResponse][Callback.onResponse] or [onFailure][Callback.onFailure]
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/test/java/okhttp3/CallKotlinTest.kt
import okhttp3.TestUtil.assertSuppressed import okhttp3.internal.DoubleInetAddressDns import okhttp3.internal.connection.RealConnection import okhttp3.internal.connection.RealConnection.Companion.IDLE_CONNECTION_HEALTHY_NS import okhttp3.internal.http.RecordingProxySelector import okhttp3.testing.Flaky import okhttp3.testing.PlatformRule import okio.BufferedSink import org.junit.jupiter.api.Assertions.assertEquals
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 8.4K bytes - Viewed (0)