Review feedback - comments added

reactor-core/src/main/java/reactor/core/publisher/ConnectableLift.java

@@ -68,6 +68,7 @@ public String stepName() {
 
 	@Override
 	public final CoreSubscriber<? super I> subscribeOrReturn(CoreSubscriber<? super O> actual) {
+		// No need to wrap actual for CP, the Operators$LiftFunction handles it.
 		CoreSubscriber<? super I> input = liftFunction.lifter.apply(source, actual);
 
 		Objects.requireNonNull(input, "Lifted subscriber MUST NOT be null");

reactor-core/src/main/java/reactor/core/publisher/ConnectableLiftFuseable.java

@@ -70,6 +70,7 @@ public String stepName() {
 
 	@Override
 	public final CoreSubscriber<? super I> subscribeOrReturn(CoreSubscriber<? super O> actual) {
+		// No need to wrap actual for CP, the Operators$LiftFunction handles it.
 		CoreSubscriber<? super I> input = liftFunction.lifter.apply(source, actual);
 
 		Objects.requireNonNull(input, "Lifted subscriber MUST NOT be null");

reactor-core/src/main/java/reactor/core/publisher/FluxContextWriteRestoringThreadLocalsFuseable.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2016-2024 VMware Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2024 VMware Inc. or its affiliates, All Rights Reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

reactor-core/src/main/java/reactor/core/publisher/GroupedLift.java

@@ -79,6 +79,7 @@ public String stepName() {
 
 	@Override
 	public void subscribe(CoreSubscriber<? super O> actual) {
+		// No need to wrap actual for CP, the Operators$LiftFunction handles it.
 		CoreSubscriber<? super I> input = liftFunction.lifter.apply(source, actual);
 
 		Objects.requireNonNull(input, "Lifted subscriber MUST NOT be null");

reactor-core/src/main/java/reactor/core/publisher/GroupedLiftFuseable.java

@@ -81,6 +81,7 @@ public String stepName() {
 
 	@Override
 	public void subscribe(CoreSubscriber<? super O> actual) {
+		// No need to wrap actual for CP, the Operators$LiftFunction handles it.
 		CoreSubscriber<? super I> input = liftFunction.lifter.apply(source, actual);
 
 		Objects.requireNonNull(input, "Lifted subscriber MUST NOT be null");

reactor-core/src/main/java/reactor/core/publisher/MonoLift.java

@@ -37,6 +37,7 @@ final class MonoLift<I, O> extends InternalMonoOperator<I, O> {
 
 	@Override
 	public CoreSubscriber<? super I> subscribeOrReturn(CoreSubscriber<? super O> actual) {
+		// No need to wrap actual for CP, the Operators$LiftFunction handles it.
 		CoreSubscriber<? super I> input = liftFunction.lifter.apply(source, actual);
 
 		Objects.requireNonNull(input, "Lifted subscriber MUST NOT be null");

reactor-core/src/main/java/reactor/core/publisher/MonoLiftFuseable.java

@@ -55,6 +55,7 @@ public Object scanUnsafe(Attr key) {
 
 	@Override
 	public CoreSubscriber<? super I> subscribeOrReturn(CoreSubscriber<? super O> actual) {
+		// No need to wrap actual for CP, the Operators$LiftFunction handles it.
 		CoreSubscriber<? super I> input = liftFunction.lifter.apply(source, actual);
 
 		Objects.requireNonNull(input, "Lifted subscriber MUST NOT be null");

reactor-core/src/main/java/reactor/core/publisher/ParallelLift.java

@@ -84,6 +84,7 @@ public void subscribe(CoreSubscriber<? super O>[] s) {
 		int i = 0;
 		while (i < subscribers.length) {
 			subscribers[i] =
+					// No need to wrap actual for CP, the Operators$LiftFunction handles it.
 					Objects.requireNonNull(liftFunction.lifter.apply(source, s[i]),
 							"Lifted subscriber MUST NOT be null");
 			i++;

reactor-core/src/main/java/reactor/core/publisher/ParallelLiftFuseable.java

@@ -88,6 +88,7 @@ public void subscribe(CoreSubscriber<? super O>[] s) {
 		while (i < subscribers.length) {
 			CoreSubscriber<? super O> actual = s[i];
 			CoreSubscriber<? super I> converted =
+					// No need to wrap actual for CP, the Operators$LiftFunction handles it.
 					Objects.requireNonNull(liftFunction.lifter.apply(source, actual), "Lifted subscriber MUST NOT be null");
 
 			Objects.requireNonNull(converted, "Lifted subscriber MUST NOT be null");