- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for isSatisfied (0.07 sec)
-
guava/src/com/google/common/util/concurrent/Monitor.java
* * @param isSatisfied the new guard's boolean condition (see {@link Guard#isSatisfied * isSatisfied()}) * @since 21.0 (but only since 33.4.0 in the Android flavor) */ public Guard newGuard(BooleanSupplier isSatisfied) { checkNotNull(isSatisfied, "isSatisfied"); return new Guard(this) { @Override public boolean isSatisfied() { return isSatisfied.getAsBoolean();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 42.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
} @Override public boolean isSatisfied() { return state() == NEW; } } private final Guard isStoppable = new IsStoppableGuard(); @WeakOuter private final class IsStoppableGuard extends Guard { IsStoppableGuard() { super(AbstractService.this.monitor); } @Override public boolean isSatisfied() { return state().compareTo(RUNNING) <= 0;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 20.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractService.java
} @Override public boolean isSatisfied() { return state() == NEW; } } private final Guard isStoppable = new IsStoppableGuard(); @WeakOuter private final class IsStoppableGuard extends Guard { IsStoppableGuard() { super(AbstractService.this.monitor); } @Override public boolean isSatisfied() { return state().compareTo(RUNNING) <= 0;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 20.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java
private volatile boolean satisfied; public TestGuard(boolean satisfied) { super(MonitorTestCase.this.monitor); this.satisfied = satisfied; } @Override public boolean isSatisfied() { return this.satisfied; } public void setSatisfied(boolean satisfied) { this.satisfied = satisfied; } } private final boolean interruptible;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 8K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 22.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
AwaitHealthGuard() { super(ServiceManagerState.this.monitor); } @Override @GuardedBy("ServiceManagerState.this.monitor") public boolean isSatisfied() { // All services have started or some service has terminated/failed. return states.count(RUNNING) == numberOfServices || states.contains(STOPPING) || states.contains(TERMINATED)
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 33.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
static class FlagGuard extends Monitor.Guard { private boolean satisfied; protected FlagGuard(Monitor monitor) { super(monitor); } @Override public boolean isSatisfied() { return satisfied; } public void setSatisfied(boolean satisfied) { this.satisfied = satisfied; } } private final Method method;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 27K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java
final PriorityQueue<E> q; final Monitor monitor = new Monitor(true); private final Monitor.Guard notEmpty = new Monitor.Guard(monitor) { @Override public boolean isSatisfied() { return !q.isEmpty(); } }; /** * Creates a {@code MonitorBasedPriorityBlockingQueue} with the default initial capacity (11) that
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 18.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/authenticator/JavaNetAuthenticator.kt
) return request .newBuilder() .header(credentialHeader, credential) .build() } } return null // No challenges were satisfied! } @Throws(IOException::class) private fun Proxy.connectToInetAddress( url: HttpUrl, dns: Dns, ): InetAddress = when (type()) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/CacheControl.kt
import okhttp3.internal.commonToString /** * A Cache-Control header with cache directives from a server or client. These directives set policy * on what responses can be stored, and which requests can be satisfied by those stored responses. * * See [RFC 7234, 5.2](https://tools.ietf.org/html/rfc7234#section-5.2). */ class CacheControl internal constructor( /**
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 10K bytes - Viewed (0)