Skip to content

Commit 52595d3

Browse files
Clarify unittest for observeOn with ImmediateScheduler
- spying was removed since it wasn't being used and ImmediateScheduler results in no scheduling being done.
1 parent 2611684 commit 52595d3

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

rxjava-core/src/main/java/rx/operators/OperationObserveOn.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -67,14 +67,14 @@ public Subscription call(final Observer<T> observer) {
6767

6868
public static class UnitTest {
6969

70+
/**
71+
* This is testing a no-op path since it uses Schedulers.immediate() which will not do scheduling.
72+
*/
7073
@Test
7174
@SuppressWarnings("unchecked")
7275
public void testObserveOn() {
73-
74-
Scheduler scheduler = spy(OperatorTester.UnitTest.forwardingScheduler(Schedulers.immediate()));
75-
7676
Observer<Integer> observer = mock(Observer.class);
77-
Observable.create(observeOn(Observable.from(1, 2, 3), scheduler)).subscribe(observer);
77+
Observable.create(observeOn(Observable.from(1, 2, 3), Schedulers.immediate())).subscribe(observer);
7878

7979
verify(observer, times(1)).onNext(1);
8080
verify(observer, times(1)).onNext(2);

0 commit comments

Comments
 (0)