- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 471 for Callable (0.05 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
public void testReturning() throws Exception { assertThat(Callables.returning(null).call()).isNull(); Object value = new Object(); Callable<Object> callable = Callables.returning(value); assertThat(callable.call()).isEqualTo(value); // Expect the same value on subsequent calls assertThat(callable.call()).isEqualTo(value); } @J2ktIncompatible @GwtIncompatible
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
public void testReturning() throws Exception { assertThat(Callables.returning(null).call()).isNull(); Object value = new Object(); Callable<Object> callable = Callables.returning(value); assertThat(callable.call()).isEqualTo(value); // Expect the same value on subsequent calls assertThat(callable.call()).isEqualTo(value); } @J2ktIncompatible @GwtIncompatible
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
TestExecutor(MockExecutor mock) { super(mock); } @Override protected <T> Callable<T> wrapTask(Callable<T> callable) { return new WrappedCallable<T>(callable); } @Override protected Runnable wrapTask(Runnable command) { return new WrappedRunnable(command); } }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
} } private static List<Callable<String>> createTasks(int n) { List<Callable<String>> callables = new ArrayList<>(); for (int i = 0; i < n; i++) { callables.add(Callables.returning(RESULT_VALUE + i)); } return callables; } private static final class WrappedCallable<T> implements Callable<T> { private final Callable<T> delegate;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 10.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
TestExecutor(MockExecutor mock) { super(mock); } @Override protected <T> Callable<T> wrapTask(Callable<T> callable) { return new WrappedCallable<T>(callable); } @Override protected Runnable wrapTask(Runnable command) { return new WrappedRunnable(command); } }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.5K bytes - Click Count (0) -
tests/test_dependency_partial.py
("/partial-callable-dependency", "partial-callable-dependency"), ("/partial-callable-gen-dependency", "partial-callable-gen-dependency"), ("/partial-async-callable-dependency", "partial-async-callable-dependency"), ( "/partial-async-callable-gen-dependency", "partial-async-callable-gen-dependency", ), (Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Wed Dec 17 21:25:59 GMT 2025 - 6.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
/** * Creates a {@code ListenableFutureTask} that will upon running, execute the given {@code * Callable}. * * @param callable the callable task * @since 10.0 */ public static <V extends @Nullable Object> ListenableFutureTask<V> create(Callable<V> callable) { return new ListenableFutureTask<>(callable); } /** * Creates a {@code ListenableFutureTask} that will upon running, execute the given {@codeCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Feb 10 11:51:21 GMT 2026 - 4.2K bytes - Click Count (0) -
tests/test_dependency_class.py
client = TestClient(app) @pytest.mark.parametrize( "route,value", [ ("/callable-dependency", "callable-dependency"), ("/callable-gen-dependency", "callable-gen-dependency"), ("/async-callable-dependency", "async-callable-dependency"), ("/async-callable-gen-dependency", "async-callable-gen-dependency"), ("/synchronous-method-dependency", "synchronous-method-dependency"),
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Wed Dec 17 21:25:59 GMT 2025 - 4.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
} } private static List<Callable<String>> createTasks(int n) { List<Callable<String>> callables = new ArrayList<>(); for (int i = 0; i < n; i++) { callables.add(Callables.returning(RESULT_VALUE + i)); } return callables; } private static final class WrappedCallable<T> implements Callable<T> { private final Callable<T> delegate;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 10.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ListeningExecutorServiceTest.java
public final class ListeningExecutorServiceTest extends TestCase { private Collection<? extends Callable<?>> recordedTasks; private long recordedTimeout; private TimeUnit recordedTimeUnit; private final ListeningExecutorService executorService = new FakeExecutorService(); public void testInvokeAny() throws Exception { Set<Callable<String>> tasks = Collections.singleton(() -> "invokeAny");Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 4.6K bytes - Click Count (0)