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 index a18256c72..3676246cb 100644 --- a/implementation/src/main/java/io/smallrye/mutiny/operators/multi/MultiConcatMapOp.java +++ b/implementation/src/main/java/io/smallrye/mutiny/operators/multi/MultiConcatMapOp.java @@ -103,13 +103,10 @@ public void onSubscribe(Flow.Subscription subscription) { private void innerOnSubscribe(Flow.Subscription subscription) { stateLock.lock(); innerUpstream = subscription; - try { - long n = demand; - if (n > 0L) { - subscription.request(n); - } - } finally { - stateLock.unlock(); + long n = demand; + stateLock.unlock(); + if (n > 0L) { + subscription.request(n); } }