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 Sep 15, 2020
1 parent 8ab3444 commit 5a12b8f
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 5a12b8f

Please sign in to comment.