Deprecate Flux* function interfaces

spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/FunctionRegistration.java

@@ -171,6 +171,7 @@ public class FunctionRegistration<T> implements BeanNameAware {
 	 * @return {@code FunctionRegistration} with the appropriately wrapped target.
 	 *
 	 */
+
 	@SuppressWarnings({ "unchecked", "rawtypes" })
 	public <S> FunctionRegistration<S> wrap() {
 		this.isFunctionSignatureSupported();

spring-cloud-function-core/src/main/java/org/springframework/cloud/function/core/FluxConsumer.java

@@ -29,7 +29,10 @@ import reactor.core.publisher.Mono;
  * @author Dave Syer
  * @author Oleg Zhurakousky
  * @see FluxedConsumer
+ *
+ * @deprecated since 3.1 no longer used by the framework
  */
+@Deprecated
 public class FluxConsumer<I>
 		extends WrappedFunction<I, Void, Flux<I>, Mono<Void>, Consumer<I>> {
 

spring-cloud-function-core/src/main/java/org/springframework/cloud/function/core/FluxFunction.java

@@ -28,7 +28,10 @@ import reactor.core.publisher.Flux;
  * @param <O> output type of target function
  * @author Mark Fisher
  * @author Oleg Zhurakousky
+ *
+ * @deprecated since 3.1 no longer used by the framework
  */
+@Deprecated
 public class FluxFunction<I, O>
 		extends WrappedFunction<I, O, Flux<I>, Flux<O>, Function<I, O>> {
 

spring-cloud-function-core/src/main/java/org/springframework/cloud/function/core/FluxSupplier.java

@@ -31,7 +31,10 @@ import reactor.core.publisher.Flux;
  *
  * @param <T> output type of target supplier
  * @author Mark Fisher
+ *
+ * @deprecated since 3.1 no longer used by the framework
  */
+@Deprecated
 public class FluxSupplier<T> implements Supplier<Flux<T>>, FluxWrapper<Supplier<T>> {
 
 	private final Supplier<T> supplier;

spring-cloud-function-core/src/main/java/org/springframework/cloud/function/core/FluxToMonoFunction.java

@@ -33,7 +33,10 @@ import reactor.core.publisher.Mono;
  * @param <O> type of {@link Mono} output of the target function
  * @author Oleg Zhurakousky
  * @since 2.0
+ *
+ * @deprecated since 3.1 no longer used by the framework
  */
+@Deprecated
 public class FluxToMonoFunction<I, O>
 		extends WrappedFunction<I, O, Flux<I>, Mono<O>, Function<Flux<I>, Mono<O>>> {
 

spring-cloud-function-core/src/main/java/org/springframework/cloud/function/core/FluxWrapper.java

@@ -19,7 +19,10 @@ package org.springframework.cloud.function.core;
 /**
  * @param <T> target type
  * @author Dave Syer
+ *
+ * @deprecated since 3.1 no longer used by the framework
  */
+@Deprecated
 public interface FluxWrapper<T> {
 
 	T getTarget();

spring-cloud-function-core/src/main/java/org/springframework/cloud/function/core/FluxedConsumer.java

@@ -31,7 +31,10 @@ import reactor.core.publisher.Mono;
  * @since 2.0.1
  * @see FluxConsumer
  *
+ * @deprecated since 3.1 no longer used by the framework
+ *
  */
+@Deprecated
 public class FluxedConsumer<I>
 		extends WrappedFunction<I, Void, Flux<I>, Mono<Void>, Consumer<Flux<I>>> {
 

spring-cloud-function-core/src/main/java/org/springframework/cloud/function/core/FluxedFunction.java

@@ -28,7 +28,10 @@ import reactor.core.publisher.Flux;
  * @param <O> output type of target function
  * @author Oleg Zhurakousky
  * @since 2.0.1
+ *
+ * @deprecated since 3.1 no longer used by the framework
  */
+@Deprecated
 public class FluxedFunction<I, O>
 		extends WrappedFunction<I, O, Flux<I>, Flux<O>, Function<Flux<I>, Flux<O>>> {
 

spring-cloud-function-core/src/main/java/org/springframework/cloud/function/core/FunctionFactoryMetadata.java

@@ -21,7 +21,10 @@ import java.lang.reflect.Method;
 /**
  * @param <F> target type
  * @author Dave Syer
+ *
+ * @deprecated since 3.1 no longer used by the framework
  */
+@Deprecated
 public interface FunctionFactoryMetadata<F> {
 
 	Method getFactoryMethod();

spring-cloud-function-core/src/main/java/org/springframework/cloud/function/core/IsolatedSupplier.java

@@ -23,7 +23,9 @@ import org.springframework.util.ClassUtils;
 /**
  * @param <T> supplied type
  * @author Dave Syer
+ * @deprecated since 3.1 no longer used by the framework
  */
+@Deprecated
 public class IsolatedSupplier<T> implements Supplier<T>, Isolated {
 
 	private final Supplier<T> supplier;

spring-cloud-function-core/src/main/java/org/springframework/cloud/function/core/MonoSupplier.java

@@ -27,7 +27,10 @@ import reactor.core.publisher.Mono;
  * @param <T> output type of target supplier
  * @author Mark Fisher
  * @since 2.1
+ *
+ * @deprecated since 3.1 no longer used by the framework
  */
+@Deprecated
 public class MonoSupplier<T> implements Supplier<Mono<T>>, FluxWrapper<Supplier<T>> {
 
 	private final Supplier<T> supplier;

spring-cloud-function-core/src/main/java/org/springframework/cloud/function/core/MonoToFluxFunction.java

@@ -28,7 +28,10 @@ import reactor.core.publisher.Mono;
  * @param <O> type of {@link Flux} output of the target function
  * @author Oleg Zhurakousky
  * @since 2.0
+ *
+ * @deprecated since 3.1 no longer used by the framework
  */
+@Deprecated
 public class MonoToFluxFunction<I, O>
 		extends WrappedFunction<I, O, Mono<I>, Flux<O>, Function<Mono<I>, Flux<O>>> {
 

spring-cloud-function-core/src/main/java/org/springframework/cloud/function/core/WrappedFunction.java

@@ -34,7 +34,10 @@ import org.reactivestreams.Publisher;
  * {@link Consumer})
  * @author Oleg Zhurakousky
  * @since 2.0.1
+ *
+ * @deprecated since 3.1 no longer used by the framework
  */
+@Deprecated
 public abstract class WrappedFunction<I, O, IP extends Publisher<I>, OP extends Publisher<O>, T>
 		implements Function<IP, OP>, FluxWrapper<T> {