From 72d37bb82404177302743f39d8ddee50d26b705d Mon Sep 17 00:00:00 2001
From: Dariusz Seweryn <dariusz.seweryn@polidea.com>
Date: Wed, 31 Jul 2019 17:35:35 +0200
Subject: [PATCH] Fixed library tests

According to the below link some test assertions are now not available. Made substitute extensions.
https://github.com/ReactiveX/RxJava/pull/6526
---
 .../extensions/TestSubscriberExtension.groovy | 20 +++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git a/rxandroidble/src/test/groovy/com/polidea/rxandroidble2/extensions/TestSubscriberExtension.groovy b/rxandroidble/src/test/groovy/com/polidea/rxandroidble2/extensions/TestSubscriberExtension.groovy
index 9476889c5..47a761d6a 100644
--- a/rxandroidble/src/test/groovy/com/polidea/rxandroidble2/extensions/TestSubscriberExtension.groovy
+++ b/rxandroidble/src/test/groovy/com/polidea/rxandroidble2/extensions/TestSubscriberExtension.groovy
@@ -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()