Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for SettableFuture (0.19 sec)

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

              }
            };
    
        final SettableFuture<String> delayedSuccess = SettableFuture.create();
        final SettableFuture<String> delayedFailed = SettableFuture.create();
        final SettableFuture<String> delayedCancelled = SettableFuture.create();
    
        final SettableFuture<String> delegateForDelayedRuntimeException = SettableFuture.create();
        final ListenableFuture<String> delayedRuntimeException =
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

      public void testFromFluentFuture() {
        FluentFuture<String> f = FluentFuture.from(SettableFuture.<String>create());
        assertThat(FluentFuture.from(f)).isSameInstanceAs(f);
      }
    
      public void testFromFluentFuturePassingAsNonFluent() {
        ListenableFuture<String> f = FluentFuture.from(SettableFuture.<String>create());
        assertThat(FluentFuture.from(f)).isSameInstanceAs(f);
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 5.7K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

              }
            };
    
        final SettableFuture<String> delayedSuccess = SettableFuture.create();
        final SettableFuture<String> delayedFailed = SettableFuture.create();
        final SettableFuture<String> delayedCancelled = SettableFuture.create();
    
        final SettableFuture<String> delegateForDelayedRuntimeException = SettableFuture.create();
        final ListenableFuture<String> delayedRuntimeException =
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

      public void testFromFluentFuture() {
        FluentFuture<String> f = FluentFuture.from(SettableFuture.<String>create());
        assertThat(FluentFuture.from(f)).isSameInstanceAs(f);
      }
    
      public void testFromFluentFuturePassingAsNonFluent() {
        ListenableFuture<String> f = FluentFuture.from(SettableFuture.<String>create());
        assertThat(FluentFuture.from(f)).isSameInstanceAs(f);
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 5.7K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

      // together.  Now it should only be limited by available memory (and time)
      public void testSetFuture_stackOverflow() {
        SettableFuture<String> orig = SettableFuture.create();
        SettableFuture<String> prev = orig;
        for (int i = 0; i < 100000; i++) {
          SettableFuture<String> curr = SettableFuture.create();
          prev.setFuture(curr);
          prev = curr;
        }
        // prev represents the 'innermost' future
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

      // together.  Now it should only be limited by available memory (and time)
      public void testSetFuture_stackOverflow() {
        SettableFuture<String> orig = SettableFuture.create();
        SettableFuture<String> prev = orig;
        for (int i = 0; i < 100000; i++) {
          SettableFuture<String> curr = SettableFuture.create();
          prev.setFuture(curr);
          prev = curr;
        }
        // prev represents the 'innermost' future
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/FuturesGetDoneTest.java

        try {
          getDone(immediateCancelledFuture());
          fail();
        } catch (CancellationException expected) {
        }
      }
    
      public void testPending() throws ExecutionException {
        try {
          getDone(SettableFuture.create());
          fail();
        } catch (IllegalStateException expected) {
        }
      }
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 2.2K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetDoneTest.java

        try {
          getDone(immediateCancelledFuture());
          fail();
        } catch (CancellationException expected) {
        }
      }
    
      public void testPending() throws ExecutionException {
        try {
          getDone(SettableFuture.create());
          fail();
        } catch (IllegalStateException expected) {
        }
      }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 2.2K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetUnchecked_cancelled() {
        SettableFuture<String> future = SettableFuture.create();
        future.cancel(true);
        try {
          getUnchecked(future);
          fail();
        } catch (CancellationException expected) {
        }
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 4.3K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        WeakReference<Object> ref = new WeakReference<>(toBeGCed);
        final SettableFuture<@Nullable Void> settableFuture = SettableFuture.create();
        ListenableFuture<?> ignored =
            serializer.submitAsync(
                new AsyncCallable<@Nullable Void>() {
                  @Override
                  public ListenableFuture<@Nullable Void> call() {
                    return settableFuture;
                  }
                },
                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)
Back to top