Skip to content

Commit 2765090

Browse files
FromIterable: Remove superfluous onComplete
As per discussion at ReactiveX#770 (comment)
1 parent f90ba89 commit 2765090

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public OperatorFromIterable(Iterable<? extends T> iterable) {
3838
public void call(Operator<? super T> o) {
3939
for (T i : is) {
4040
if (o.isUnsubscribed()) {
41-
break;
41+
return;
4242
}
4343
o.onNext(i);
4444
}

0 commit comments

Comments
 (0)