- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 580 for calling (0.03 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java
} @RetainedLocalRef Object localValue = valueField; if (localValue != null & notInstanceOfDelegatingToFuture(localValue)) { return getDoneValue(localValue); } // we delay calling nanoTime until we know we will need to either park or spin long endNanos = remainingNanos > 0 ? System.nanoTime() + remainingNanos : 0; long_wait_loop: if (remainingNanos >= SPIN_THRESHOLD_NANOS) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 33.2K bytes - Viewed (0) -
docs/features/interceptors.md
### Application Interceptors Interceptors are registered as either _application_ or _network_ interceptors. We'll use the `LoggingInterceptor` defined above to show the difference. Register an _application_ interceptor by calling `addInterceptor()` on `OkHttpClient.Builder`: ```java OkHttpClient client = new OkHttpClient.Builder() .addInterceptor(new LoggingInterceptor()) .build(); Request request = new Request.Builder()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 8.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/DiscreteDomain.java
private DiscreteDomain(boolean supportsFastOffset) { this.supportsFastOffset = supportsFastOffset; } /** * Returns, conceptually, "origin + distance", or equivalently, the result of calling {@link * #next} on {@code origin} {@code distance} times. */ C offset(C origin, long distance) { C current = origin; checkNonnegative(distance, "distance"); for (long i = 0; i < distance; i++) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Feb 13 17:34:21 UTC 2025 - 10.4K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* instances: * * <ul> * <li>If you receive them from an {@code java.util.concurrent.ExecutorService}, convert that * service to a {@link ListeningExecutorService}, usually by calling {@link * MoreExecutors#listeningDecorator(java.util.concurrent.ExecutorService) * MoreExecutors.listeningDecorator}. * <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method,
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFuture.java
* instances: * * <ul> * <li>If you receive them from an {@code java.util.concurrent.ExecutorService}, convert that * service to a {@link ListeningExecutorService}, usually by calling {@link * MoreExecutors#listeningDecorator(java.util.concurrent.ExecutorService) * MoreExecutors.listeningDecorator}. * <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method,
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
guava/src/com/google/common/hash/LittleEndianByteArray.java
| ((source[offset + 3] & 0xFF) << 24); } /** * Indicates that the load and store operations will be very efficient because of use of VarHandle * or Unsafe. May be useful for calling code to fall back on an alternative implementation that is * slower than those implementations but faster than the pure-Java mask-and-shift. */ static boolean usingFastPath() { return byteArray.usesFastPath();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 12 03:49:18 UTC 2025 - 12.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/trans2/Trans2SetFileInformationResponseTest.java
void testHasMoreElements() { // Initially should have more elements if error code is 0 assertTrue(response.hasMoreElements()); // After calling nextElement once, isPrimary becomes false but hasMore is still true initially response.nextElement(); // Can still have more elements assertTrue(response.hasMoreElements()); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
// // If an exception is thrown by the subclass then we need to make sure that the service // notices and transitions to the FAILED state. We do it by calling notifyFailed directly // because the service does not monitor the state of the future so if the exception is not // caught and forwarded to the service the task would stop executing but the service would
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/FauxveridesTest.java
} public void testImmutableSortedMultiset() { doHasAllFauxveridesTest(ImmutableSortedMultiset.class, ImmutableMultiset.class); } /* * Demonstrate that ClassCastException is possible when calling * ImmutableSorted{Set,Map}.copyOf(), whose type parameters we are unable to * restrict (see ImmutableSortedSetFauxverideShim). */ public void testImmutableSortedMapCopyOfMap() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue Jul 08 18:32:10 UTC 2025 - 9.4K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComNTCreateAndX.java
*/ static final int FILE_OVERWRITE = 0x4; /* * Open the file and overwrite it's contents or create it if it does not exist * aka CREATE_ALWAYS (according to the wire when calling CreateFile) */ static final int FILE_OVERWRITE_IF = 0x5; // create options static final int FILE_WRITE_THROUGH = 0x00000002; static final int FILE_SEQUENTIAL_ONLY = 0x00000004;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 8.6K bytes - Viewed (0)