- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 176 for ongoing (0.12 sec)
-
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
private static void executeListener(Runnable runnable, Executor executor) { try { executor.execute(runnable); } catch (Exception e) { // sneaky checked exception // Log it and keep going -- bad runnable and/or executor. Don't punish the other runnables if // we're given a bad one. We only catch Exception because we want Errors to propagate up. log.get() .log( Level.SEVERE,
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 6.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
while (currentTask != self) { taskRunner.wait() } } finally { serialTaskQueue.remove(yieldCompleteTask) } // If we're yielding until we're exhausted and a task run, keep going until a task doesn't run. if (strategy == ResumePriority.AfterOtherTasks && otherTasksStarted) { return yieldUntil(strategy, condition) } } private enum class ResumePriority {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 11.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt
assumeNotWindows() enableProtocol(Protocol.HTTP_2) val body = MockSocketHandler() .exhaustResponse() .receiveRequest("hey\n") .receiveRequest("whats going on\n") .exhaustRequest() server.enqueue( MockResponse .Builder() .clearHeaders() .addHeader("h1", "v1") .addHeader("h2", "v2") .socketHandler(body)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 24.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
*/ private static TestCase generateGuardWithWrongMonitorTestCase( Method method, boolean fair1, boolean fair2) { boolean timed = isTimed(method); // Not going to bother with all timeouts, just 0ms. return new TestCase(method.getName() + (timed ? "(0ms)" : "()") + "/WrongMonitor->IMSE") { @Override protected void runTest() throws Throwable {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 27K bytes - Viewed (0) -
docs/en/docs/tutorial/bigger-applications.md
/// tip In this example, the variable is called `router`, but you can name it however you want. /// We are going to include this `APIRouter` in the main `FastAPI` app, but first, let's check the dependencies and another `APIRouter`. ## Dependencies { #dependencies } We see that we are going to need some dependencies used in several places of the application.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 19.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionList.java
private static void executeListener(Runnable runnable, Executor executor) { try { executor.execute(runnable); } catch (Exception e) { // sneaky checked exception // Log it and keep going -- bad runnable and/or executor. Don't punish the other runnables if // we're given a bad one. We only catch Exception because we want Errors to propagate up. log.get() .log( Level.SEVERE,
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 6.9K bytes - Viewed (0) -
src/test/java/jcifs/smb/SIDCacheImplTest.java
SID s2 = sid("S-1-5-21-1-2-3-1002"); jcifs.SID[] in = new jcifs.SID[] { s1, s2 }; // Stub sendrecv to emulate successful RPC response doAnswer(inv -> { // Capture the outgoing RPC and populate result fields as the server would Object msg = inv.getArgument(0); assertTrue(msg instanceof jcifs.dcerpc.msrpc.MsrpcLookupSids);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 14K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/CompactHashMap.java
extends AbstractMap<K, V> implements Serializable { /* * TODO: Make this a drop-in replacement for j.u. versions, actually drop them in, and test the * world. Figure out what sort of space-time tradeoff we're actually going to get here with the * *Map variants. This class is particularly hard to benchmark, because the benefit is not only in * less allocation, but also having the GC do less work to scan the heap because of fewer
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 35.7K bytes - Viewed (0) -
docs/en/docs/tutorial/first-steps.md
Normally you use: * `POST`: to create data. * `GET`: to read data. * `PUT`: to update data. * `DELETE`: to delete data. So, in OpenAPI, each of the HTTP methods is called an "operation". We are going to call them "**operations**" too. #### Define a *path operation decorator* { #define-a-path-operation-decorator } {* ../../docs_src/first_steps/tutorial001.py hl[6] *}
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 11K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/AndXServerMessageBlock.java
* A word about communicating header info to andx smbs * * This is where we recursively invoke the provided andx smb * object to write it's parameter words and bytes to our outgoing * array. Incedentally when these andx smbs are created they are not * necessarily populated with header data because they're not writing
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 15.8K bytes - Viewed (0)