Skip to content

Commit c857ba3

Browse files
committed
Removed unused interface
1 parent 8fa3a37 commit c857ba3

File tree

2 files changed

+17
-14
lines changed

2 files changed

+17
-14
lines changed

rxjava-core/src/main/java/rx/schedulers/EventLoopsScheduler.java

Lines changed: 15 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,18 @@
1+
/**
2+
* Copyright 2014 Netflix, Inc.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
116
package rx.schedulers;
217

318
import java.util.concurrent.ThreadFactory;
@@ -7,7 +22,6 @@
722
import rx.Scheduler;
823
import rx.Subscription;
924
import rx.functions.Action0;
10-
import rx.schedulers.NewThreadScheduler.NewThreadWorker.Remover;
1125
import rx.schedulers.NewThreadScheduler.NewThreadWorker.ScheduledAction;
1226
import rx.subscriptions.CompositeSubscription;
1327
import rx.subscriptions.Subscriptions;

rxjava-core/src/main/java/rx/schedulers/NewThreadScheduler.java

Lines changed: 2 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -69,11 +69,7 @@ public Worker createWorker() {
6969

7070
@Override
7171
public Subscription schedule(final Action0 action) {
72-
return schedule(action, null);
73-
}
74-
75-
/* package */Subscription schedule(final Action0 action, final OnActionComplete onComplete) {
76-
return scheduleActual(action, 0, null);
72+
return schedule(action, 0, null);
7773
}
7874

7975
@Override
@@ -98,7 +94,7 @@ public Subscription schedule(final Action0 action, long delayTime, TimeUnit unit
9894
}
9995

10096
/** Remove a child subscription from a composite when unsubscribing. */
101-
public static final class Remover implements Subscription {
97+
private static final class Remover implements Subscription {
10298
final Subscription s;
10399
final CompositeSubscription parent;
104100
final AtomicBoolean once;
@@ -185,11 +181,4 @@ public boolean isUnsubscribed() {
185181
}
186182

187183
}
188-
189-
/* package */static interface OnActionComplete {
190-
191-
public void complete(Subscription s);
192-
193-
}
194-
195184
}

0 commit comments

Comments
 (0)