Skip to content

Commit

Permalink
Fixed library tests
Browse files Browse the repository at this point in the history
According to the below link some test assertions are now not available. Made substitute extensions.
ReactiveX/RxJava#6526
  • Loading branch information
dariuszseweryn authored and z3ntu committed Apr 1, 2021
1 parent 4eec98b commit 08b9e31
Showing 1 changed file with 20 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,26 @@ class TestSubscriberExtension {
subscriber.assertValueSequence(values)
}

static <T> void assertTerminated(final TestObserver<T> subscriber) {
try {
subscriber.assertComplete()
} catch (Throwable ignored) {
subscriber.assertError({ true })
}
}

static <T> void assertNotTerminated(final TestObserver<T> subscriber) {
subscriber.assertNotComplete()
subscriber.assertNoErrors()
if (subscriber.isDisposed()) {
throw AssertionError("TestObserver is disposed")
}
}

static <T> void assertErrorMessage(final TestObserver<T> subscriber, final String errorMessage) {
subscriber.assertError { it.message == errorMessage }
}

static boolean assertAllBatchesSmaller(final TestSubscriber<byte[]> subscriber, int maxBatchSize) {
def emittedValues = subscriber.values()
def size = emittedValues.size()
Expand Down

0 comments on commit 08b9e31

Please sign in to comment.