Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for eventuallyClose (0.23 sec)

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

                      @Override
                      public TestCloseable call(DeferredCloser closer) throws Exception {
                        closer.eventuallyClose(closeable1, closingExecutor);
                        closer.eventuallyClose(closeable2, closingExecutor);
                        return closeable3;
                      }
                    },
                    executor)
                .transform(
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

                      @Override
                      public TestCloseable call(DeferredCloser closer) throws Exception {
                        closer.eventuallyClose(closeable1, closingExecutor);
                        closer.eventuallyClose(closeable2, closingExecutor);
                        return closeable3;
                      }
                    },
                    executor)
                .transform(
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 74.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

        /**
         * Computes a result, or throws an exception if unable to do so.
         *
         * <p>Any objects that are passed to {@link DeferredCloser#eventuallyClose(Object, Executor)
         * closer.eventuallyClose()} will be closed when the {@link ClosingFuture} pipeline is done (but
         * not before this method completes), even if this method throws or the pipeline is cancelled.
         */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 98.5K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java

            ClosingFuture.submit(
                new ClosingCallable<Closeable>() {
                  @Override
                  public Closeable call(DeferredCloser closer) throws Exception {
                    return closer.eventuallyClose(mockCloseable, executor);
                  }
                },
                executor);
        closingFuture.finishToValueAndCloser(
            new NoOpValueAndCloserConsumer<>(), finishToValueAndCloserExecutor);
        assertThrows(
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 5.7K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToFutureTest.java

            ClosingFuture.submit(
                new ClosingCallable<Closeable>() {
                  @Override
                  public Closeable call(DeferredCloser closer) throws Exception {
                    return closer.eventuallyClose(mockCloseable, executor);
                  }
                },
                executor);
        FluentFuture<Closeable> unused = closingFuture.finishToFuture();
        assertThrows(
            IllegalStateException.class,
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 3.7K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java

            ClosingFuture.submit(
                new ClosingCallable<Closeable>() {
                  @Override
                  public Closeable call(DeferredCloser closer) throws Exception {
                    return closer.eventuallyClose(mockCloseable, executor);
                  }
                },
                executor);
        closingFuture.finishToValueAndCloser(
            new NoOpValueAndCloserConsumer<>(), finishToValueAndCloserExecutor);
        assertThrows(
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 5.7K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToFutureTest.java

            ClosingFuture.submit(
                new ClosingCallable<Closeable>() {
                  @Override
                  public Closeable call(DeferredCloser closer) throws Exception {
                    return closer.eventuallyClose(mockCloseable, executor);
                  }
                },
                executor);
        FluentFuture<Closeable> unused = closingFuture.finishToFuture();
        assertThrows(
            IllegalStateException.class,
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 3.7K bytes
    - Viewed (0)
Back to top