Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

3.x: Remove redundant interface declarations #7438

Merged
merged 2 commits into from
Jun 6, 2022
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ protected void subscribeActual(Subscriber<? super U> s) {
}

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

final Supplier<U> bufferSupplier;
final Publisher<B> boundary;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -244,8 +244,7 @@ public final boolean isEmpty() {
}
}

static final class ObserveOnSubscriber<T> extends BaseObserveOnSubscriber<T>
implements FlowableSubscriber<T> {
static final class ObserveOnSubscriber<T> extends BaseObserveOnSubscriber<T> {

private static final long serialVersionUID = -4547113800637756442L;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ protected void subscribeActual(Subscriber<? super U> s) {

static final class ToListSubscriber<T, U extends Collection<? super T>>
extends DeferredScalarSubscription<U>
implements FlowableSubscriber<T>, Subscription {
implements FlowableSubscriber<T> {

private static final long serialVersionUID = -8134157938864266736L;
Subscription upstream;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ protected void subscribeActual(Observer<? super U> t) {
}

static final class BufferExactBoundaryObserver<T, U extends Collection<? super T>, B>
extends QueueDrainObserver<T, U, U> implements Observer<T>, Disposable {
extends QueueDrainObserver<T, U, U> implements Disposable {

final Supplier<U> bufferSupplier;
final ObservableSource<B> boundary;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@
* worker but doesn't perform task-tracking operations.
*
*/
public class NewThreadWorker extends Scheduler.Worker implements Disposable {
public class NewThreadWorker extends Scheduler.Worker {
private final ScheduledExecutorService executor;

volatile boolean disposed;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ public Disposable scheduleDirect(@NonNull Runnable run, long delay, TimeUnit uni
return EmptyDisposable.INSTANCE;
}

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

private final AtomicInteger wip = new AtomicInteger();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -560,6 +560,7 @@ public void checkParallelFlowable() {
for (Class<?> interfaces : AllFunctionals.class.getInterfaces()) {
defaultValues.put(interfaces, af);
}
defaultValues.put(Subscriber.class, af);
defaultValues.put(TimeUnit.class, TimeUnit.SECONDS);
defaultValues.put(Scheduler.class, Schedulers.single());
defaultValues.put(BackpressureStrategy.class, BackpressureStrategy.MISSING);
Expand Down Expand Up @@ -926,7 +927,7 @@ static final class AllFunctionals
Function3, Function4, Function5, Function6, Function7, Function8, Function9,
FlowableOnSubscribe, ObservableOnSubscribe, SingleOnSubscribe, MaybeOnSubscribe, CompletableOnSubscribe,
FlowableTransformer, ObservableTransformer, SingleTransformer, MaybeTransformer, CompletableTransformer,
Subscriber, FlowableSubscriber, Observer, SingleObserver, MaybeObserver, CompletableObserver,
FlowableSubscriber, Observer, SingleObserver, MaybeObserver, CompletableObserver,
FlowableOperator, ObservableOperator, SingleOperator, MaybeOperator, CompletableOperator,
Comparator, ParallelTransformer
{
Expand Down