Skip to content

Commit 0198217

Browse files
committed
Removes unused(?) source field in OperatorDelay
1 parent f9d3e99 commit 0198217

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

src/main/java/rx/Observable.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -4127,7 +4127,7 @@ public final Observable<T> delay(long delay, TimeUnit unit) {
41274127
* @see <a href="http://reactivex.io/documentation/operators/delay.html">ReactiveX operators documentation: Delay</a>
41284128
*/
41294129
public final Observable<T> delay(long delay, TimeUnit unit, Scheduler scheduler) {
4130-
return lift(new OperatorDelay<T>(this, delay, unit, scheduler));
4130+
return lift(new OperatorDelay<T>(delay, unit, scheduler));
41314131
}
41324132

41334133
/**

src/main/java/rx/internal/operators/OperatorDelay.java

+1-3
Original file line numberDiff line numberDiff line change
@@ -32,13 +32,11 @@
3232
*/
3333
public final class OperatorDelay<T> implements Operator<T, T> {
3434

35-
final Observable<? extends T> source;
3635
final long delay;
3736
final TimeUnit unit;
3837
final Scheduler scheduler;
3938

40-
public OperatorDelay(Observable<? extends T> source, long delay, TimeUnit unit, Scheduler scheduler) {
41-
this.source = source;
39+
public OperatorDelay(long delay, TimeUnit unit, Scheduler scheduler) {
4240
this.delay = delay;
4341
this.unit = unit;
4442
this.scheduler = scheduler;

0 commit comments

Comments
 (0)