- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for scheduler (0.26 sec)
-
mockwebserver/README.md
```java public void test() throws Exception { // Create a MockWebServer. These are lean enough that you can create a new // instance for every unit test. MockWebServer server = new MockWebServer(); // Schedule some responses. server.enqueue(new MockResponse().setBody("hello, world!")); server.enqueue(new MockResponse().setBody("sup, bra?")); server.enqueue(new MockResponse().setBody("yo dog")); // Start the server.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Dec 17 15:34:10 GMT 2023 - 5K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
addressStates[address]?.scheduleOpener() } fun scheduleCloser() { cleanupQueue.schedule(cleanupTask) } /** * Ensure enough connections open to [address] to satisfy its [ConnectionPool.AddressPolicy]. * If there are already enough connections, we're done. * If not, we create one and then schedule the task to run again immediately. */ private fun openConnections(state: AddressState): Long {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
@get:Synchronized @set:Synchronized var maxSize: Long = maxSize set(value) { field = value if (initialized) { cleanupQueue.schedule(cleanupTask) // Trim the existing store if necessary. } } /* * This cache uses a journal file named "journal". A typical journal file looks like this: * * libcore.io.DiskLruCache
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
override fun contentType() = delegate.contentType() override fun isDuplex() = true override fun writeTo(sink: BufferedSink) { executorService.schedule({ try { delegate.writeTo(sink) sink.close() } catch (e: IOException) { throw RuntimeException(e) } }, delayMillis, TimeUnit.MILLISECONDS) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 23.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
object : Task("task one") { val schedules = mutableListOf(200.µs) override fun runOnce(): Long { if (schedules.isNotEmpty()) { redQueue.schedule(this, schedules.removeAt(0)) // Add it at the end also. } log += "scheduledTasks=${redQueue.scheduledTasks}" return -1L } } redQueue.schedule(task, 100.µs)
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) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
// If the task is already scheduled, take the earlier of the two times. val existingIndex = futureTasks.indexOf(task) if (existingIndex != -1) { if (task.nextExecuteNanoTime <= executeNanoTime) { taskRunner.logger.taskLog(task, this) { "already scheduled" } return false } futureTasks.removeAt(existingIndex) // Already scheduled later: reschedule below! }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
* ---------- * * Tasks control their recurrence schedule. The [runOnce] function returns -1L to signify that the * task should not be executed again. Otherwise it returns a delay until the next execution. * * A task has at most one next execution. If the same task instance is scheduled multiple times, the * earliest one wins. This applies to both executions scheduled with [TaskRunner.Queue.schedule] and * those implied by the returned execution delay.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/CancelCall.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.9K bytes - Viewed (0) -
.github/renovate.json
{ "$schema": "https://docs.renovatebot.com/renovate-schema.json", "extends": [ "config:base", ":dependencyDashboard", "schedule:weekly" ], "labels": ["renovate"], "ignoreDeps": [ "com.squareup.okhttp3:okhttp", "com.squareup.okhttp3:okhttp-tls", "com.squareup.okhttp3:mockwebserver" ], "packageRules": [ { "matchPackageNames": ["org.objenesis:objenesis"], "allowedVersions": "<=2.6"
Json - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Feb 18 14:22:17 GMT 2023 - 1.1K bytes - Viewed (0) -
docs/recipes.md
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Feb 18 08:52:22 GMT 2022 - 40.2K bytes - Viewed (1)