diff --git a/src/main/java/rx/internal/util/SubscriptionIndexedRingBuffer.java b/src/main/java/rx/internal/util/SubscriptionIndexedRingBuffer.java index 6dcb2d566d..8809d67814 100644 --- a/src/main/java/rx/internal/util/SubscriptionIndexedRingBuffer.java +++ b/src/main/java/rx/internal/util/SubscriptionIndexedRingBuffer.java @@ -75,11 +75,9 @@ public void remove(final int n) { return; } Subscription t = subscriptions.remove(n); + // if we removed successfully we then need to call unsubscribe on it if (t != null) { - // if we removed successfully we then need to call unsubscribe on it - if (t != null) { - t.unsubscribe(); - } + t.unsubscribe(); } }