Remove unnecessary suppression

hivemq · Nov 14, 2023 · 3795e35 · 3795e35
1 parent 52b1b24
commit 3795e35
Show file tree

Hide file tree

Showing 5 changed files with 0 additions and 7 deletions.
diff --git a/.../com/hivemq/client2/internal/mqtt/handler/publish/incoming/MqttSubscribedPublishFlow.java b/.../com/hivemq/client2/internal/mqtt/handler/publish/incoming/MqttSubscribedPublishFlow.java
@@ -47,7 +47,6 @@ public class MqttSubscribedPublishFlow extends MqttIncomingPublishFlow implement
     @Override
     public void onSuccess(final @NotNull MqttSubAck subAck) {
         if (subscriber instanceof FlowableWithSingleSubscriber) {
-            //noinspection unchecked
             ((FlowableWithSingleSubscriber<? super Mqtt5Publish, ? super Mqtt5SubAck>) subscriber).onSingle(subAck);
         }
     }

diff --git a/src/main/java/com/hivemq/client2/internal/rx/operators/FlowableWithSingleCombine.java b/src/main/java/com/hivemq/client2/internal/rx/operators/FlowableWithSingleCombine.java
@@ -157,7 +157,6 @@ static <F, S> void split(
             final @NotNull WithSingleSubscriber<? super F, ? super S> subscriber) {
 
         if (subscriber instanceof WithSingleConditionalSubscriber) {
-            //noinspection unchecked
             source.subscribe(new SplitSubscriber.Conditional<>(
                     (WithSingleConditionalSubscriber<? super F, ? super S>) subscriber));
         } else {

diff --git a/src/main/java/com/hivemq/client2/internal/rx/operators/FlowableWithSingleMap.java b/src/main/java/com/hivemq/client2/internal/rx/operators/FlowableWithSingleMap.java
@@ -65,7 +65,6 @@ private FlowableWithSingleMap(
     @Override
     protected void subscribeActual(final @NotNull Subscriber<? super FM> subscriber) {
         if (subscriber instanceof ConditionalSubscriber) {
-            //noinspection unchecked
             final ConditionalSubscriber<? super FM> conditional = (ConditionalSubscriber<? super FM>) subscriber;
             source.subscribeBoth(new MapSubscriber.Conditional<>(conditional, flowableMapper, singleMapper));
         } else {
@@ -76,7 +75,6 @@ protected void subscribeActual(final @NotNull Subscriber<? super FM> subscriber)
     @Override
     protected void subscribeBothActual(final @NotNull WithSingleSubscriber<? super FM, ? super SM> subscriber) {
         if (subscriber instanceof WithSingleConditionalSubscriber) {
-            //noinspection unchecked
             final WithSingleConditionalSubscriber<? super FM, ? super SM> conditional =
                     (WithSingleConditionalSubscriber<? super FM, ? super SM>) subscriber;
             source.subscribeBoth(new WithSingleMapSubscriber.Conditional<>(conditional, flowableMapper, singleMapper));

diff --git a/src/main/java/com/hivemq/client2/internal/rx/operators/FlowableWithSingleMapError.java b/src/main/java/com/hivemq/client2/internal/rx/operators/FlowableWithSingleMapError.java
@@ -49,7 +49,6 @@ public FlowableWithSingleMapError(
     @Override
     protected void subscribeActual(final @NotNull Subscriber<? super F> subscriber) {
         if (subscriber instanceof ConditionalSubscriber) {
-            //noinspection unchecked
             final ConditionalSubscriber<? super F> conditional = (ConditionalSubscriber<? super F>) subscriber;
             source.subscribe(new MapErrorSubscriber.Conditional<>(conditional, errorMapper));
         } else {
@@ -60,7 +59,6 @@ protected void subscribeActual(final @NotNull Subscriber<? super F> subscriber)
     @Override
     protected void subscribeBothActual(final @NotNull WithSingleSubscriber<? super F, ? super S> subscriber) {
         if (subscriber instanceof WithSingleConditionalSubscriber) {
-            //noinspection unchecked
             final WithSingleConditionalSubscriber<? super F, ? super S> conditional =
                     (WithSingleConditionalSubscriber<? super F, ? super S>) subscriber;
             source.subscribeBoth(new WithSingleMapErrorSubscriber.Conditional<>(conditional, errorMapper));

diff --git a/src/main/java/com/hivemq/client2/rx/FlowableWithSingle.java b/src/main/java/com/hivemq/client2/rx/FlowableWithSingle.java
@@ -186,7 +186,6 @@ public abstract class FlowableWithSingle<F, S> extends Flowable<F> implements Pu
     @SchedulerSupport(SchedulerSupport.NONE)
     public final void subscribeBoth(final @NotNull WithSingleSubscriber<? super F, ? super S> subscriber) {
         if (subscriber instanceof FlowableWithSingleSubscriber) {
-            //noinspection unchecked
             subscribeBoth((FlowableWithSingleSubscriber<? super F, ? super S>) subscriber);
         } else {
             Checks.notNull(subscriber, "Subscriber");