- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,033 for Call (0.2 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
public void testReturning() throws Exception { assertNull(Callables.returning(null).call()); Object value = new Object(); Callable<Object> callable = Callables.returning(value); assertSame(value, callable.call()); // Expect the same value on subsequent calls assertSame(value, callable.call()); } @J2ktIncompatible @GwtIncompatible public void testAsAsyncCallable() throws Exception {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 5.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
ListenableFuture<Boolean> future2 = serializer.submit( new Callable<Boolean>() { @Override public Boolean call() { return blockingCallable.isRunning(); } }, directExecutor());
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
ListenableFuture<Boolean> future2 = serializer.submit( new Callable<Boolean>() { @Override public Boolean call() { return blockingCallable.isRunning(); } }, directExecutor());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
for (PerListenerQueue<L> queue : listeners) { queue.add(event, label); } } } /** * Dispatches all events enqueued prior to this call, serially and in order, for every listener. * * <p>Note: this method is idempotent and safe to call from any thread */ public void dispatch() { // iterate by index to avoid concurrent modification exceptions
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/MutableNetwork.java
*/ @CanIgnoreReturnValue boolean addEdge(EndpointPair<N> endpoints, E edge); /** * Removes {@code node} if it is present; all edges incident to {@code node} will also be removed. * * @return {@code true} if the network was modified as a result of this call */ @CanIgnoreReturnValue boolean removeNode(N node); /** * Removes {@code edge} from this network, if it is present. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 26 17:43:39 GMT 2021 - 4.4K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/GraphConstants.java
static final String MULTIPLE_EDGES_CONNECTING = "Cannot call edgeConnecting() when parallel edges exist between %s and %s. Consider calling " + "edgesConnecting() instead."; static final String PARALLEL_EDGES_NOT_ALLOWED = "Nodes %s and %s are already connected by a different edge. To construct a graph " + "that allows parallel edges, call allowsParallelEdges(true) on the Builder.";
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jan 22 17:29:38 GMT 2024 - 3.1K bytes - Viewed (0) -
android/guava/src/com/google/common/io/LineBuffer.java
* or carriage return followed immediately by a linefeed. * * <p>Subclasses must implement {@link #handleLine}, call {@link #add} to pass character data, and * call {@link #finish} at the end of stream. * * @author Chris Nokleberg * @since 1.0 */ @J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault abstract class LineBuffer {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 3.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/PopulatedCachesTest.java
Entry<Object, Object> entry = warmed.get(i - WARMUP_MIN); assertTrue(cache.asMap().containsKey(entry.getKey())); assertTrue(cache.asMap().containsValue(entry.getValue())); // this getUnchecked() call shouldn't be a cache miss; verified below assertEquals(entry.getValue(), cache.getUnchecked(entry.getKey())); } assertEquals(WARMUP_SIZE, cache.stats().missCount()); checkValidState(cache); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 15K bytes - Viewed (0) -
guava/src/com/google/common/collect/AbstractSequentialIterator.java
} /** * Returns the element that follows {@code previous}, or returns {@code null} if no elements * remain. This method is invoked during each call to {@link #next()} in order to compute the * result of a <i>future</i> call to {@code next()}. */ @CheckForNull protected abstract T computeNext(T previous); @Override public final boolean hasNext() { return nextOrNull != null; }
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Fri Jul 09 17:31:04 GMT 2021 - 2.4K bytes - Viewed (0) -
guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); taskDone = false; Callable<Boolean> task = new Callable<Boolean>() { @Override public Boolean call() { taskDone = true; return taskDone; } }; List<Future<Boolean>> futureList = executor.invokeAll(ImmutableList.of(task), 10, TimeUnit.MILLISECONDS);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.7K bytes - Viewed (0)