Skip to content

Commit 3d11e67

Browse files
committed
3.x: Remove redundant interface declarations
1 parent f359ca1 commit 3d11e67

File tree

7 files changed

+7
-8
lines changed

7 files changed

+7
-8
lines changed

src/main/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableBufferExactBoundary.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ protected void subscribeActual(Subscriber<? super U> s) {
4545
}
4646

4747
static final class BufferExactBoundarySubscriber<T, U extends Collection<? super T>, B>
48-
extends QueueDrainSubscriber<T, U, U> implements FlowableSubscriber<T>, Subscription, Disposable {
48+
extends QueueDrainSubscriber<T, U, U> implements Subscription, Disposable {
4949

5050
final Supplier<U> bufferSupplier;
5151
final Publisher<B> boundary;

src/main/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableObserveOn.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -244,8 +244,7 @@ public final boolean isEmpty() {
244244
}
245245
}
246246

247-
static final class ObserveOnSubscriber<T> extends BaseObserveOnSubscriber<T>
248-
implements FlowableSubscriber<T> {
247+
static final class ObserveOnSubscriber<T> extends BaseObserveOnSubscriber<T> {
249248

250249
private static final long serialVersionUID = -4547113800637756442L;
251250

src/main/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableToList.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ protected void subscribeActual(Subscriber<? super U> s) {
4646

4747
static final class ToListSubscriber<T, U extends Collection<? super T>>
4848
extends DeferredScalarSubscription<U>
49-
implements FlowableSubscriber<T>, Subscription {
49+
implements FlowableSubscriber<T> {
5050

5151
private static final long serialVersionUID = -8134157938864266736L;
5252
Subscription upstream;

src/main/java/io/reactivex/rxjava3/internal/operators/observable/ObservableBufferExactBoundary.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ protected void subscribeActual(Observer<? super U> t) {
4343
}
4444

4545
static final class BufferExactBoundaryObserver<T, U extends Collection<? super T>, B>
46-
extends QueueDrainObserver<T, U, U> implements Observer<T>, Disposable {
46+
extends QueueDrainObserver<T, U, U> implements Disposable {
4747

4848
final Supplier<U> bufferSupplier;
4949
final ObservableSource<B> boundary;

src/main/java/io/reactivex/rxjava3/internal/schedulers/NewThreadWorker.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
* worker but doesn't perform task-tracking operations.
2727
*
2828
*/
29-
public class NewThreadWorker extends Scheduler.Worker implements Disposable {
29+
public class NewThreadWorker extends Scheduler.Worker {
3030
private final ScheduledExecutorService executor;
3131

3232
volatile boolean disposed;

src/main/java/io/reactivex/rxjava3/internal/schedulers/TrampolineScheduler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public Disposable scheduleDirect(@NonNull Runnable run, long delay, TimeUnit uni
6262
return EmptyDisposable.INSTANCE;
6363
}
6464

65-
static final class TrampolineWorker extends Scheduler.Worker implements Disposable {
65+
static final class TrampolineWorker extends Scheduler.Worker {
6666
final PriorityBlockingQueue<TimedRunnable> queue = new PriorityBlockingQueue<>();
6767

6868
private final AtomicInteger wip = new AtomicInteger();

src/test/java/io/reactivex/rxjava3/validators/ParamValidationCheckerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -926,7 +926,7 @@ static final class AllFunctionals
926926
Function3, Function4, Function5, Function6, Function7, Function8, Function9,
927927
FlowableOnSubscribe, ObservableOnSubscribe, SingleOnSubscribe, MaybeOnSubscribe, CompletableOnSubscribe,
928928
FlowableTransformer, ObservableTransformer, SingleTransformer, MaybeTransformer, CompletableTransformer,
929-
Subscriber, FlowableSubscriber, Observer, SingleObserver, MaybeObserver, CompletableObserver,
929+
FlowableSubscriber, Observer, SingleObserver, MaybeObserver, CompletableObserver,
930930
FlowableOperator, ObservableOperator, SingleOperator, MaybeOperator, CompletableOperator,
931931
Comparator, ParallelTransformer
932932
{

0 commit comments

Comments
 (0)