- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 129 for ready (0.12 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
} } /** * Returns an immediately-executable task for the calling thread to execute, sleeping as necessary * until one is ready. If there are no ready queues, or if other threads have everything under * control this will return null. If there is more than a single task ready to execute immediately * this will start another thread to handle that work. */ fun awaitTaskToRun(): Task? { lock.assertHeld()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
factory.close() } inner class FakePlan( val id: Int, ) : RoutePlanner.Plan { var planningThrowable: Throwable? = null var canceled = false var connectState = ConnectState.READY val connection = factory.newConnection( pool = pool, route = factory.newRoute(address), idleAtNanos = defaultConnectionIdleAtNanos, ) var retry: FakePlan? = null
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-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
}, logger = logger, ) /** Runs all tasks that are ready. Used by the test thread only. */ fun runTasks() { advanceUntil(nanoTime) } /** Advance the simulated clock, then runs tasks that are ready. Used by the test thread only. */ fun advanceUntil(newTime: Long) { taskRunner.assertThreadDoesntHoldLock()
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) -
.teamcity/src/main/kotlin/configurations/FlakyTestQuarantine.kt
Plain Text - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Wed Apr 24 08:17:56 GMT 2024 - 3.4K bytes - Viewed (0) -
.teamcity/src/main/kotlin/projects/CheckProject.kt
} var prevStage: Stage? = null val previousPerformanceTestPasses: MutableList<PerformanceTestsPass> = mutableListOf() model.stages.forEach { stage -> if (isSecurityFork() && stage.stageName > StageName.READY_FOR_RELEASE) { return@forEach } val stageProject = StageProject(model, functionalTestBucketProvider, performanceTestBucketProvider, stage, previousPerformanceTestPasses)
Plain Text - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Wed Apr 24 03:34:53 GMT 2024 - 3.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
TimeUnit.SECONDS, SynchronousQueue(), threadFactory("$okHttpName Dispatcher", false), ) } return executorServiceOrNull!! } /** Ready async calls in the order they'll be run. */ private val readyAsyncCalls = ArrayDeque<AsyncCall>() /** Running asynchronous calls. Includes canceled calls that haven't finished yet. */
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) -
docs/en/docs/fastapi-cli.md
For production you would use `fastapi run` instead. 🚀 Internally, **FastAPI CLI** uses <a href="https://www.uvicorn.org" class="external-link" target="_blank">Uvicorn</a>, a high-performance, production-ready, ASGI server. 😎 ## `fastapi dev` When you run `fastapi dev`, it will run on development mode.
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Fri May 03 23:25:16 GMT 2024 - 6.1K bytes - Viewed (0) -
docs/en/docs/async.md
## In a hurry? <abbr title="too long; didn't read"><strong>TL;DR:</strong></abbr> If you are using third party libraries that tell you to call them with `await`, like: ```Python results = await some_library() ``` Then, declare your *path operation functions* with `async def` like: ```Python hl_lines="2" @app.get('/') async def read_results(): results = await some_library() return results
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 23K bytes - Viewed (0) -
README.md
<summary>About the command <code>fastapi dev main.py</code>...</summary> The command `fastapi dev` reads your `main.py` file, detects the **FastAPI** app in it, and starts a server using <a href="https://www.uvicorn.org" class="external-link" target="_blank">Uvicorn</a>. By default, `fastapi dev` will start with auto-reload enabled for local development.
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu May 02 22:37:31 GMT 2024 - 22.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
// Close the raw socket so we don't end up doing synchronous I/O. rawSocket?.closeQuietly() } override fun socket(): Socket = socket!! /** Returns true if this connection is ready to host new streams. */ fun isHealthy(doExtensiveChecks: Boolean): Boolean { lock.assertNotHeld() val nowNs = System.nanoTime() val rawSocket = this.rawSocket!! val socket = this.socket!!
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0)