Skip to content

Commit

Permalink
style: remove redundant method overrides
Browse files Browse the repository at this point in the history
jponge committed Mar 17, 2024

Verified

This commit was signed with the committer’s verified signature.
jponge Julien Ponge
1 parent e839a59 commit 402fd72
Showing 3 changed files with 0 additions and 27 deletions.
Original file line number Diff line number Diff line change
@@ -286,16 +286,6 @@ public void onItem(T item) {
index = i + 1;
}

@Override
public void onFailure(Throwable t) {
Subscription subscription = getAndSetUpstreamSubscription(CANCELLED);
if (subscription != CANCELLED) {
downstream.onFailure(t);
} else {
Infrastructure.handleDroppedException(t);
}
}

@Override
public void onCompletion() {
Subscription subscription = getAndSetUpstreamSubscription(CANCELLED);
Original file line number Diff line number Diff line change
@@ -6,10 +6,8 @@
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;

import io.smallrye.mutiny.Context;
import io.smallrye.mutiny.Multi;
import io.smallrye.mutiny.helpers.Subscriptions;
import io.smallrye.mutiny.subscription.ContextSupport;
import io.smallrye.mutiny.subscription.DemandPacer;
import io.smallrye.mutiny.subscription.MultiSubscriber;

@@ -45,15 +43,6 @@ private static class MultiSubscriptionPacerProcessor<T> extends MultiOperatorPro
this.pacer = pacer;
}

@Override
public Context context() {
if (downstream instanceof ContextSupport) {
return ((ContextSupport) downstream).context();
} else {
return Context.empty();
}
}

private void demandAndSchedule(ScheduledExecutorService executor) {
if (upstream == Subscriptions.CANCELLED) {
return;
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package io.smallrye.mutiny.operators.multi;

import java.util.concurrent.Flow.Subscription;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.Predicate;

@@ -58,11 +57,6 @@ public RepeatProcessor(Multi<? extends T> upstream, MultiSubscriber<? super T> d
this.delay = delay;
}

@Override
public void onSubscribe(Subscription s) {
setOrSwitchUpstream(s);
}

/**
* Subscribes to the source again via trampolining.
*/

0 comments on commit 402fd72

Please sign in to comment.