T
- type of the value contained in the CompletableFuture
.public class FlinkCompletableFutureAssert<T> extends org.assertj.core.api.AbstractCompletableFutureAssert<FlinkCompletableFutureAssert<T>,T>
CompletableFutureAssert
, that allows asserting
futures without relying on timeouts.Modifier and Type | Class and Description |
---|---|
static class |
FlinkCompletableFutureAssert.WithThrowable
A strongly typed alternative to
WithThrowable . |
Modifier and Type | Method and Description |
---|---|
FlinkCompletableFutureAssert.WithThrowable |
eventuallyFails()
An equivalent of
AbstractCompletableFutureAssert.failsWithin(Duration) , that doesn't rely on timeouts. |
<E extends Throwable> |
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(Duration duration)
Assert that
CompletableFuture will not complete within a fixed duration. |
failsWithin, failsWithin, hasFailed, hasFailedWithThrowableThat, hasNotFailed, isCancelled, isCompleted, isCompletedExceptionally, isCompletedWithValue, isCompletedWithValueMatching, isCompletedWithValueMatching, isDone, isNotCancelled, isNotCompleted, isNotCompletedExceptionally, isNotDone, newObjectAssert, succeedsWithin, succeedsWithin, succeedsWithin, succeedsWithin
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
public org.assertj.core.api.ObjectAssert<T> eventuallySucceeds()
AbstractCompletableFutureAssert.succeedsWithin(Duration)
, that doesn't rely on timeouts.public FlinkCompletableFutureAssert.WithThrowable eventuallyFails()
AbstractCompletableFutureAssert.failsWithin(Duration)
, that doesn't rely on timeouts.public <E extends Throwable> org.assertj.core.api.ThrowableAssertAlternative<E> eventuallyFailsWith(Class<E> exceptionClass)
AbstractCompletableFutureAssert.failsWithin(Duration)
, that doesn't rely on timeouts.E
- type of the exception we expect the future to complete withexceptionClass
- type of the exception we expect the future to complete withpublic FlinkCompletableFutureAssert<T> willNotCompleteWithin(Duration duration)
CompletableFuture
will not complete within a fixed duration.
This is a replacement for FlinkMatchers.willNotComplete(Duration)
in assertj.
this
assertion object.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.