We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2192f20 commit 3f04560Copy full SHA for 3f04560
language-adaptors/rxjava-scala/src/examples/scala/rx/lang/scala/examples/TestSchedulerExample.scala
@@ -35,11 +35,14 @@ class TestSchedulerExample extends JUnitSuite {
35
verify(observer, never).onCompleted()
36
verify(observer, never).onError(any(classOf[Throwable]))
37
38
+ verify(observer, never).onNext(2L)
39
+
40
sub.unsubscribe();
41
42
scheduler.advanceTimeTo(4 seconds)
- verify(observer, never).onNext(2L)
- verify(observer, times(1)).onCompleted()
- verify(observer, never).onError(any(classOf[Throwable]))
43
44
+ // after unsubscription we expect no further events
45
+ verifyNoMoreInteractions(observer)
46
}
47
48
0 commit comments