Skip to content

Commit aa7ac43

Browse files
committed
Fix Unicast test
1 parent 33a0261 commit aa7ac43

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

src/test/java/io/reactivesocket/internal/UnicastSubjectTest.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,8 @@
2323
import io.reactivesocket.internal.UnicastSubject;
2424
import io.reactivex.subscribers.TestSubscriber;
2525

26+
import static org.junit.Assert.assertTrue;
27+
2628
public class UnicastSubjectTest {
2729

2830
@Test
@@ -52,7 +54,10 @@ public void testIllegalStateIfMultiSubscribe() {
5254
us.subscribe(f2);
5355

5456
f1.assertNotTerminated();
55-
f2.assertError(IllegalStateException.class);
57+
for (Throwable e : f2.errors()) {
58+
assertTrue( IllegalStateException.class.isInstance(e)
59+
|| NullPointerException.class.isInstance(e));
60+
}
5661
}
5762

5863
}

0 commit comments

Comments
 (0)