From 8e707bb6ebb13acf99ee29f20cfe58c1df878025 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Dariusz=20J=C4=99drzejczyk?= Date: Mon, 22 Apr 2024 15:37:32 +0200 Subject: [PATCH] Removed code which got commented-out --- .../src/main/java/reactor/core/publisher/Operators.java | 4 ---- 1 file changed, 4 deletions(-) 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));