- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for isSatisfied (0.1 sec)
-
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 Dec 26 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 Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 20.7K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 22.4K bytes - Viewed (0) -
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 Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 17:49:12 UTC 2025 - 32.9K 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 Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 17:49:12 UTC 2025 - 33.2K bytes - Viewed (1) -
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 Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 21:00:51 UTC 2025 - 27.1K 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 Dec 26 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/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 Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 10K 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 Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Authenticator.kt
*/ fun interface Authenticator { /** * Returns a request that includes a credential to satisfy an authentication challenge in * [response]. Returns null if the challenge cannot be satisfied. * * The route is best effort, it currently may not always be provided even when logically * available. It may also not be provided when an authenticator is re-used manually in anRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 5.5K bytes - Viewed (0)