fix: remove useless upstream assignment in the new concatMap

smallrye · Nov 30, 2023 · 0f2b5ca · 0f2b5ca
1 parent 83c8785
commit 0f2b5ca
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/implementation/src/main/java/io/smallrye/mutiny/operators/multi/MultiConcatMapOp.java b/implementation/src/main/java/io/smallrye/mutiny/operators/multi/MultiConcatMapOp.java
@@ -100,7 +100,6 @@ public Context context() {
         @Override
         public void onSubscribe(Subscription subscription) {
             if (UPSTREAM_UPDATER.compareAndSet(this, null, subscription)) {
-                upstream = subscription;
                 downstream.onSubscribe(this);
             } else {
                 subscription.cancel();