- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for get_state (0.37 sec)
-
tests/test_dependency_contextmanager.py
"sync_bg": "not set", } errors = [] async def get_state(): return state class AsyncDependencyError(Exception): pass class SyncDependencyError(Exception): pass class OtherDependencyError(Exception): pass async def asyncgen_state(state: Dict[str, str] = Depends(get_state)): state["/async"] = "asyncgen started" yield state["/async"]
Python - Registered: Sun Apr 21 07:19:11 GMT 2024 - Last Modified: Sat Feb 24 23:06:37 GMT 2024 - 11.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
boolean isDone() { return (getState() & (COMPLETED | CANCELLED | INTERRUPTED)) != 0; } /** Checks if the state is {@link #CANCELLED} or {@link #INTERRUPTED}. */ boolean isCancelled() { return (getState() & (CANCELLED | INTERRUPTED)) != 0; } /** Checks if the state is {@link #INTERRUPTED}. */
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed May 09 15:17:25 GMT 2018 - 13.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
boolean isDone() { return (getState() & (COMPLETED | CANCELLED | INTERRUPTED)) != 0; } /** Checks if the state is {@link #CANCELLED} or {@link #INTERRUPTED}. */ boolean isCancelled() { return (getState() & (CANCELLED | INTERRUPTED)) != 0; } /** Checks if the state is {@link #INTERRUPTED}. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 13.6K bytes - Viewed (0) -
cmd/speedtest.go
var throughputHighestResults []SpeedTestResult sendResult := func() { var result madmin.SpeedTestResult durationSecs := opts.duration.Seconds() result.GETStats.ThroughputPerSec = throughputHighestGet / uint64(durationSecs) result.GETStats.ObjectsPerSec = throughputHighestGet / uint64(opts.objectSize) / uint64(durationSecs) result.PUTStats.ThroughputPerSec = throughputHighestPut / uint64(durationSecs)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/user/cbean/cq/bs/BsUserCQ.java
return this; } public void setState_Equal(String state) { setState_Term(state, null); } public void setState_Equal(String state, ConditionOptionCall<TermQueryBuilder> opLambda) { setState_Term(state, opLambda); } public void setState_Term(String state) { setState_Term(state, null); }
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 326.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
while (!isThreadBlockedOnInstanceOf(t, blocker)) { if (t.getState() == Thread.State.TERMINATED) { throw new RuntimeException("Thread " + t + " exited unexpectedly"); } Thread.sleep(1); } } private static boolean isThreadBlockedOnInstanceOf(Thread t, Class<?> blocker) { return t.getState() == Thread.State.WAITING && blocker.isInstance(LockSupport.getBlocker(t)); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
assertTrue(future.isDone()); assertListenerRunImmediately(future); assertEquals(1, threadLocalCount.get().intValue()); otherThread.join(1000); assertEquals(Thread.State.TERMINATED, otherThread.getState()); Throwable throwable = throwableFromOtherThread.get(); assertNull( "Throwable from other thread: " + (throwable == null ? null : Throwables.getStackTraceAsString(throwable)),
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (0) -
internal/grid/connection.go
if sleep < 0 { sleep = 0 } gotState := c.State() if gotState == StateShutdown { return } if gotState != StateConnecting { // Don't print error on first attempt, // and after that only once per hour. gridLogOnceIf(c.ctx, fmt.Errorf("grid: %s connecting to %s: %w (%T) Sleeping %v (%v)", c.Local, toDial, err, err, sleep, gotState), toDial) } c.updateState(StateConnectionError)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ldap/LdapManager.java
.forEach(v -> modifyDeleteEntry(modifyList, attrInternationaliSDNNumber, v))); final String attrState = fessConfig.getLdapAttrState(); OptionalUtil.ofNullable(user.getState()).filter(StringUtil::isNotBlank).ifPresent(s -> modifyReplaceEntry(modifyList, attrState, s)) .orElse(() -> getAttributeValueList(result, attrState).stream().forEach(v -> modifyDeleteEntry(modifyList, attrState, v)));
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 65.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/user/bsentity/BsUser.java
registerModifiedProperty("roomNumber"); this.roomNumber = value; } public String getState() { checkSpecifiedProperty("state"); return convertEmptyToNull(state); } public void setState(String value) { registerModifiedProperty("state"); this.state = value; } public String getStreet() {
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 22.8K bytes - Viewed (0)