diff --git a/reactor-core/src/main/java/reactor/core/publisher/Operators.java b/reactor-core/src/main/java/reactor/core/publisher/Operators.java index 2e0c19044b..06e1c3464f 100644 --- a/reactor-core/src/main/java/reactor/core/publisher/Operators.java +++ b/reactor-core/src/main/java/reactor/core/publisher/Operators.java @@ -2707,10 +2707,6 @@ static final LiftFunction liftScannable( // top of a custom Publisher so that user's lifter can also see // have the Context properly restored to ThreadLocal values. (pub, sub) -> { -// CoreSubscriber userLiftedSub = -// lifter.apply(Scannable.from(pub), -// restoreContextOnSubscriberIfAutoCPEnabledInLift(pub, sub)); -// return restoreContextOnSubscriberIfAutoCPEnabledInLift(pub, userLiftedSub); CoreSubscriber userLiftedSub = lifter.apply(Scannable.from(pub), restoreContextOnSubscriberIfAutoCPEnabled(pub, sub));