Skip to content

Commit 46dbc86

Browse files
committed
save allocation in OperatorSkipTimed
1 parent 45f6072 commit 46dbc86

File tree

1 file changed

+13
-7
lines changed

1 file changed

+13
-7
lines changed

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

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -42,13 +42,8 @@ public OperatorSkipTimed(long time, TimeUnit unit, Scheduler scheduler) {
4242
public Subscriber<? super T> call(final Subscriber<? super T> child) {
4343
final Worker worker = scheduler.createWorker();
4444
child.add(worker);
45-
final AtomicBoolean gate = new AtomicBoolean();
46-
worker.schedule(new Action0() {
47-
@Override
48-
public void call() {
49-
gate.set(true);
50-
}
51-
}, time, unit);
45+
final AtomicBooleanAction gate = new AtomicBooleanAction();
46+
worker.schedule(gate, time, unit);
5247
return new Subscriber<T>(child) {
5348

5449
@Override
@@ -77,4 +72,15 @@ public void onCompleted() {
7772
}
7873
};
7974
}
75+
76+
final static class AtomicBooleanAction extends AtomicBoolean implements Action0 {
77+
78+
private static final long serialVersionUID = 8308944559386967982L;
79+
80+
@Override
81+
public void call() {
82+
set(true);
83+
}
84+
85+
}
8086
}

0 commit comments

Comments
 (0)