Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 57 for isInstanceOf (0.06 seconds)

  1. guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

          assertThat(command).isInstanceOf(WrappedRunnable.class);
          lastMethodCalled = "scheduleRunnable";
          lastDelay = delay;
          lastUnit = unit;
          return null;
        }
    
        @Override
        public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) {
          assertThat(callable).isInstanceOf(WrappedCallable.class);
          lastMethodCalled = "scheduleCallable";
    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)
  2. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        public <T> Future<T> submit(Callable<T> task) {
          lastMethodCalled = "submit";
          assertThat(task).isInstanceOf(WrappedCallable.class);
          return inline.submit(task);
        }
    
        @Override
        public Future<?> submit(Runnable task) {
          lastMethodCalled = "submit";
          assertThat(task).isInstanceOf(WrappedRunnable.class);
          return inline.submit(task);
        }
    
        @Override
    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)
  3. guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java

        ExecutionException expected =
            assertThrows(
                ExecutionException.class,
                () -> service.callWithTimeout(BAD_CALLABLE, ENOUGH_MS, MILLISECONDS));
        assertThat(expected).hasCauseThat().isInstanceOf(SampleException.class);
      }
    
      public void testCallUninterruptiblyWithTimeout_goodCallableWithEnoughTime() throws Exception {
        Stopwatch stopwatch = Stopwatch.createStarted();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 9.4K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

        ListenableFuture<?> runnableFuture = e.submit(runnable);
        assertThat(runnableFuture).isInstanceOf(TrustedListenableFutureTask.class);
        assertTrue(runnableFuture.isDone());
        assertTrue(runnable.run);
    
        ListenableFuture<String> callableFuture = e.submit(new TestCallable());
        assertThat(callableFuture).isInstanceOf(TrustedListenableFutureTask.class);
        assertTrue(callableFuture.isDone());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 3.4K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

        ListenableFuture<?> runnableFuture = e.submit(runnable);
        assertThat(runnableFuture).isInstanceOf(TrustedListenableFutureTask.class);
        assertTrue(runnableFuture.isDone());
        assertTrue(runnable.run);
    
        ListenableFuture<String> callableFuture = e.submit(new TestCallable());
        assertThat(callableFuture).isInstanceOf(TrustedListenableFutureTask.class);
        assertTrue(callableFuture.isDone());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 3.4K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

          assertThat(command).isInstanceOf(WrappedRunnable.class);
          lastMethodCalled = "scheduleRunnable";
          lastDelay = delay;
          lastUnit = unit;
          return null;
        }
    
        @Override
        public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) {
          assertThat(callable).isInstanceOf(WrappedCallable.class);
          lastMethodCalled = "scheduleCallable";
    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)
  7. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

                () -> getDone(allAsList(immediateFailedFuture(new SomeError()))));
        assertThat(expected).hasCauseThat().isInstanceOf(SomeError.class);
        List<LogRecord> logged = aggregateFutureLogHandler.getStoredLogRecords();
        assertThat(logged).hasSize(1); // errors are always logged
        assertThat(logged.get(0).getThrown()).isInstanceOf(SomeError.class);
      }
    
      /** All as list will log extra exceptions that have already occurred. */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

                () -> getDone(allAsList(immediateFailedFuture(new SomeError()))));
        assertThat(expected).hasCauseThat().isInstanceOf(SomeError.class);
        List<LogRecord> logged = aggregateFutureLogHandler.getStoredLogRecords();
        assertThat(logged).hasSize(1); // errors are always logged
        assertThat(logged.get(0).getThrown()).isInstanceOf(SomeError.class);
      }
    
      /** All as list will log extra exceptions that have already occurred. */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java

        ExecutionException expected =
            assertThrows(
                ExecutionException.class,
                () -> service.callWithTimeout(BAD_CALLABLE, ENOUGH_MS, MILLISECONDS));
        assertThat(expected).hasCauseThat().isInstanceOf(SampleException.class);
      }
    
      public void testCallUninterruptiblyWithTimeout_goodCallableWithEnoughTime() throws Exception {
        Stopwatch stopwatch = Stopwatch.createStarted();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 9.4K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        public <T> Future<T> submit(Callable<T> task) {
          lastMethodCalled = "submit";
          assertThat(task).isInstanceOf(WrappedCallable.class);
          return inline.submit(task);
        }
    
        @Override
        public Future<?> submit(Runnable task) {
          lastMethodCalled = "submit";
          assertThat(task).isInstanceOf(WrappedRunnable.class);
          return inline.submit(task);
        }
    
        @Override
    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)
Back to Top