Package org.apache.flink.core.testutils

Class FlinkCompletableFutureAssert<T>

    • Field Summary

      • Fields inherited from class org.assertj.core.api.AbstractAssert

        actual, info, myself, objects, throwUnsupportedExceptionOnEquals

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      FlinkCompletableFutureAssert.WithThrowable eventuallyFails()
      An equivalent of AbstractCompletableFutureAssert.failsWithin(Duration), that doesn't rely on timeouts.
      <E extends Throwable>
      org.assertj.core.api.ThrowableAssertAlternative<E>      		 eventuallyFailsWith​(Class<E> exceptionClass)
      An equivalent of AbstractCompletableFutureAssert.failsWithin(Duration), that doesn't rely on timeouts.
      org.assertj.core.api.ObjectAssert<T> eventuallySucceeds()
      An equivalent of AbstractCompletableFutureAssert.succeedsWithin(Duration), that doesn't rely on timeouts.
      FlinkCompletableFutureAssert<T> willNotCompleteWithin​(java.time.Duration duration)
      Assert that CompletableFuture will not complete within a fixed duration.

      • Methods inherited from class org.assertj.core.api.AbstractCompletableFutureAssert

        failsWithin, failsWithin, hasFailed, hasFailedWithThrowableThat, hasNotFailed, isCancelled, isCompleted, isCompletedExceptionally, isCompletedWithValue, isCompletedWithValueMatching, isCompletedWithValueMatching, isDone, isNotCancelled, isNotCompleted, isNotCompletedExceptionally, isNotDone, newObjectAssert, succeedsWithin, succeedsWithin, succeedsWithin, succeedsWithin

      • Methods inherited from class org.assertj.core.api.AbstractAssert

        areEqual, asInstanceOf, asList, assertionError, asString, describedAs, descriptionText, doesNotHave, doesNotHaveSameClassAs, doesNotHaveSameHashCodeAs, doesNotHaveToString, equals, extracting, extracting, failure, failureWithActualExpected, failWithActualExpectedAndMessage, failWithMessage, getWritableAssertionInfo, has, hashCode, hasSameClassAs, hasSameHashCodeAs, hasToString, inBinary, inHexadecimal, is, isElementOfCustomAssert, isEqualTo, isExactlyInstanceOf, isIn, isIn, isInstanceOf, isInstanceOfAny, isInstanceOfSatisfying, isNot, isNotEqualTo, isNotExactlyInstanceOf, isNotIn, isNotIn, isNotInstanceOf, isNotInstanceOfAny, isNotNull, isNotOfAnyClassIn, isNotSameAs, isNull, isOfAnyClassIn, isSameAs, matches, matches, newListAssertInstance, overridingErrorMessage, overridingErrorMessage, satisfies, satisfies, satisfies, satisfiesAnyOf, satisfiesAnyOf, satisfiesAnyOfForProxy, satisfiesForProxy, setCustomRepresentation, setDescriptionConsumer, setPrintAssertionsDescription, throwAssertionError, usingComparator, usingComparator, usingDefaultComparator, usingRecursiveComparison, usingRecursiveComparison, withFailMessage, withFailMessage, withRepresentation, withThreadDumpOnError

      • Methods inherited from interface org.assertj.core.api.Descriptable

        as, as, as, describedAs

    • Method Detail

      • eventuallySucceeds

        public org.assertj.core.api.ObjectAssert<T> eventuallySucceeds()
        An equivalent of AbstractCompletableFutureAssert.succeedsWithin(Duration), that doesn't rely on timeouts.
        Returns:
        a new assertion object on the future's result

      • eventuallyFails

        public FlinkCompletableFutureAssert.WithThrowable eventuallyFails()
        An equivalent of AbstractCompletableFutureAssert.failsWithin(Duration), that doesn't rely on timeouts.
        Returns:
        a new assertion instance on the future's exception.

      • eventuallyFailsWith

        public <E extends Throwable> org.assertj.core.api.ThrowableAssertAlternative<E> eventuallyFailsWith​(Class<E> exceptionClass)
        An equivalent of AbstractCompletableFutureAssert.failsWithin(Duration), that doesn't rely on timeouts.
        Type Parameters:
        E - type of the exception we expect the future to complete with
        Parameters:
        exceptionClass - type of the exception we expect the future to complete with
        Returns:
        a new assertion instance on the future's exception.