Skip to content

Commit 59b59b2

Browse files
OnSubscribe: DelaySubscribe -> UnsafeSubscribe
This could cause an unwanted unsubscribe to be propagate because of the `SafeSubscriber`
1 parent af4fc88 commit 59b59b2

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

rxjava-core/src/main/java/rx/internal/operators/OnSubscribeDelay.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ public Observable<T> call(T x) {
5555
worker.schedule(e, delay, unit);
5656
return Observable.create(e);
5757
}
58-
})).subscribe(child);
58+
})).unsafeSubscribe(child);
5959
}
6060

6161
/**

0 commit comments

Comments
 (0)