We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 12ee7c9 commit 7cc3790Copy full SHA for 7cc3790
src/test/java/hu/akarnokd/rxjava3/interop/RxJavaInteropTest.java
@@ -1663,4 +1663,14 @@ public void v1ObservableIsUnsubscribedOnCompletion2() {
1663
1664
verify(onUnsubscribe).call();
1665
}
1666
+
1667
+ @Test
1668
+ public void flowableV3toObservableV1SourceUnsubscribed() {
1669
+ rx.Subscription s = new FlowableV3ToObservableV1.SourceSubscriber<Integer>(
1670
+ new rx.observers.TestSubscriber<Integer>());
1671
1672
+ assertFalse(s.isUnsubscribed());
1673
+ s.unsubscribe();
1674
+ assertTrue(s.isUnsubscribed());
1675
+ }
1676
0 commit comments