Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for finishToValueAndCloser (0.24 sec)

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

        ValueAndCloser<?> unused = finishToValueAndCloser(closingFuture);
        waitUntilClosed(closingFuture);
        futureCancelled.countDown();
      }
    
      private <V> ValueAndCloser<V> finishToValueAndCloser(ClosingFuture<V> closingFuture) {
        final CountDownLatch valueAndCloserSet = new CountDownLatch(1);
        closingFuture.finishToValueAndCloser(
            new ValueAndCloserConsumer<V>() {
              @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java

        ValueAndCloser<?> unused = finishToValueAndCloser(closingFuture);
        waitUntilClosed(closingFuture);
        futureCancelled.countDown();
      }
    
      private <V> ValueAndCloser<V> finishToValueAndCloser(ClosingFuture<V> closingFuture) {
        final CountDownLatch valueAndCloserSet = new CountDownLatch(1);
        closingFuture.finishToValueAndCloser(
            new ValueAndCloserConsumer<V>() {
              @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

       */
      public void finishToValueAndCloser(
          final ValueAndCloserConsumer<? super V> consumer, Executor executor) {
        checkNotNull(consumer);
        if (!compareAndUpdateState(OPEN, WILL_CREATE_VALUE_AND_CLOSER)) {
          switch (state.get()) {
            case SUBSUMED:
              throw new IllegalStateException(
                  "Cannot call finishToValueAndCloser() after deriving another step");
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 08 19:36:35 UTC 2024
    - 98.5K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToFutureTest.java

                    return closer.eventuallyClose(mockCloseable, executor);
                  }
                },
                executor);
        closingFuture.finishToValueAndCloser(new NoOpValueAndCloserConsumer<>(), directExecutor());
        assertThrows(
            IllegalStateException.class,
            () -> {
              FluentFuture<Closeable> unused = closingFuture.finishToFuture();
            });
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 3.7K bytes
    - Viewed (0)
Back to top