Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for Kistner (0.37 sec)

  1. guava-tests/test/com/google/common/cache/NullCacheTest.java

      QueuingRemovalListener<Object, Object> listener;
    
      @Override
      protected void setUp() {
        listener = queuingRemovalListener();
      }
    
      public void testGet() {
        Object computed = new Object();
        LoadingCache<Object, Object> cache =
            CacheBuilder.newBuilder()
                .maximumSize(0)
                .removalListener(listener)
                .build(constantLoader(computed));
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 4.4K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java

      }
    
      /**
       * Verify that the listener completes in a reasonable amount of time, and Asserts that the future
       * returns the expected data.
       *
       * @throws Throwable if the listener isn't called or if it resulted in a throwable or if the
       *     result doesn't match the expected value.
       */
      public void assertSuccess(Object expectedData) throws Throwable {
        // Verify that the listener executed in a reasonable amount of time.
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Fri May 12 18:12:42 GMT 2023
    - 3K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ImmediateFuture.java

      }
    
      @Override
      @SuppressWarnings("CatchingUnchecked") // sneaky checked exception
      public void addListener(Runnable listener, Executor executor) {
        checkNotNull(listener, "Runnable was null.");
        checkNotNull(executor, "Executor was null.");
        try {
          executor.execute(listener);
        } catch (Exception e) { // sneaky checked exception
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 3.5K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertEquals(1, listenerLatch.getCount());
        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
        // Finish the task by unblocking the task latch.  Then wait for the
        // listener to be called by blocking on the listener latch.
        taskLatch.countDown();
        assertEquals(25, task.get().intValue());
        assertTrue(listenerLatch.await(5, TimeUnit.SECONDS));
        assertTrue(task.isDone());
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 4.7K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

              throw EXCEPTION;
          }
          return outputFuture;
        }
      }
    
      public void testFutureGetThrowsFunctionException() throws Exception {
        inputFuture.set(EXCEPTION_DATA);
        listener.assertException(EXCEPTION);
      }
    
      public void testFutureGetThrowsCancellationIfInputCancelled() throws Exception {
        inputFuture.cancel(true); // argument is ignored
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.1K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

       * after executing them.
       *
       * @param listener the listener to run when the computation is complete
       * @param executor the executor to run the listener in
       * @throws RejectedExecutionException if we tried to execute the listener immediately but the
       *     executor rejected it.
       */
      void addListener(Runnable listener, Executor executor);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Jun 26 21:13:41 GMT 2023
    - 8K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractChainedListenableFutureTest.java

      protected SettableFuture<Integer> inputFuture;
      protected ListenableFuture<T> resultFuture;
      protected MockFutureListener listener;
    
      @Override
      protected void setUp() throws Exception {
        super.setUp();
    
        inputFuture = SettableFuture.create();
        resultFuture = buildChainingFuture(inputFuture);
        listener = new MockFutureListener(resultFuture);
      }
    
      public void testFutureGetBeforeCallback() throws Exception {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 3.4K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

     * guaranteed to execute. There is no guarantee, however, that listeners will be executed in the
     * order that they are added.
     *
     * <p>Exceptions thrown by a listener will be propagated up to the executor. Any exception thrown
     * during {@code Executor.execute} (e.g., a {@code RejectedExecutionException} or an exception
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

              throw EXCEPTION;
          }
          return outputFuture;
        }
      }
    
      public void testFutureGetThrowsFunctionException() throws Exception {
        inputFuture.set(EXCEPTION_DATA);
        listener.assertException(EXCEPTION);
      }
    
      public void testFutureGetThrowsCancellationIfInputCancelled() throws Exception {
        inputFuture.cancel(true); // argument is ignored
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.1K bytes
    - Viewed (0)
  10. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/ListenableFuture.java

     */
    @ElementTypesAreNonnullByDefault
    public interface ListenableFuture<V extends @Nullable Object> extends Future<V>, IThenable<V> {
      void addListener(Runnable listener, Executor executor);
    
      /** Note that this method is not expected to be overridden. */
      @JsMethod
      @Override
      default <R extends @Nullable Object> IThenable<R> then(
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Oct 24 18:27:19 GMT 2023
    - 3.9K bytes
    - Viewed (1)
Back to top