Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 471 for Callable (0.05 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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 {@code
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 4.2K bytes
    - Click Count (0)
  8. 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)
  9. 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)
  10. 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)
Back to Top