Skip to content

Commit 63d2400

Browse files
committed
Fixed the issue ReactiveX#521
1 parent 8d77fbf commit 63d2400

File tree

2 files changed

+5
-6
lines changed

2 files changed

+5
-6
lines changed

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,6 @@ public void call() {
7878
@Override
7979
public void call() {
8080
wrapped.unsubscribe();
81-
observer.onCompleted();
8281
}
8382
});
8483
}

rxjava-core/src/test/java/rx/operators/OperationIntervalTest.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ public void testInterval() {
6666
sub.unsubscribe();
6767
scheduler.advanceTimeTo(4, TimeUnit.SECONDS);
6868
verify(observer, never()).onNext(2L);
69-
verify(observer, times(1)).onCompleted();
69+
verify(observer, never()).onCompleted();
7070
verify(observer, never()).onError(any(Throwable.class));
7171
}
7272

@@ -101,11 +101,11 @@ public void testWithMultipleSubscribersStartingAtSameTime() {
101101
scheduler.advanceTimeTo(4, TimeUnit.SECONDS);
102102

103103
verify(observer, never()).onNext(2L);
104-
verify(observer, times(1)).onCompleted();
104+
verify(observer, never()).onCompleted();
105105
verify(observer, never()).onError(any(Throwable.class));
106106

107107
verify(observer2, never()).onNext(2L);
108-
verify(observer2, times(1)).onCompleted();
108+
verify(observer2, never()).onCompleted();
109109
verify(observer2, never()).onError(any(Throwable.class));
110110
}
111111

@@ -141,11 +141,11 @@ public void testWithMultipleStaggeredSubscribers() {
141141
sub2.unsubscribe();
142142

143143
inOrder1.verify(observer, never()).onNext(anyLong());
144-
inOrder1.verify(observer, times(1)).onCompleted();
144+
inOrder1.verify(observer, never()).onCompleted();
145145
verify(observer, never()).onError(any(Throwable.class));
146146

147147
inOrder2.verify(observer2, never()).onNext(anyLong());
148-
inOrder2.verify(observer2, times(1)).onCompleted();
148+
inOrder2.verify(observer2, never()).onCompleted();
149149
verify(observer2, never()).onError(any(Throwable.class));
150150
}
151151

0 commit comments

Comments
 (0)