Merge 780e487 into 1.1.13

reactor · Nov 13, 2023 · fcbdbb7 · fcbdbb7
2 parents 8b3ef54 + 780e487
commit fcbdbb7
Show file tree

Hide file tree

Showing 117 changed files with 526 additions and 525 deletions.
diff --git a/reactor-netty-core/src/jarFileTest/java/reactor/netty/AbstractJarFileTest.java b/reactor-netty-core/src/jarFileTest/java/reactor/netty/AbstractJarFileTest.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2019-2021 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2019-2023 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.
@@ -24,7 +24,7 @@
 import static java.util.Collections.emptyMap;
 
 /**
- * A helper class to access the content of a shaded JAR
+ * A helper class to access the content of a shaded JAR.
  */
 class AbstractJarFileTest {
 

diff --git a/reactor-netty-core/src/main/java/reactor/netty/ByteBufFlux.java b/reactor-netty-core/src/main/java/reactor/netty/ByteBufFlux.java
@@ -48,7 +48,7 @@
 public class ByteBufFlux extends FluxOperator<ByteBuf, ByteBuf> {
 
 	/**
-	 * Decorate as {@link ByteBufFlux}
+	 * Decorate as {@link ByteBufFlux}.
 	 *
 	 * @param source publisher to decorate
 	 *
@@ -59,7 +59,7 @@ public static ByteBufFlux fromInbound(Publisher<?> source) {
 	}
 
 	/**
-	 * Decorate as {@link ByteBufFlux}
+	 * Decorate as {@link ByteBufFlux}.
 	 *
 	 * @param source publisher to decorate
 	 * @param allocator the channel {@link ByteBufAllocator}
@@ -73,7 +73,7 @@ public static ByteBufFlux fromInbound(Publisher<?> source, ByteBufAllocator allo
 
 
 	/**
-	 * Decorate as {@link ByteBufFlux}
+	 * Decorate as {@link ByteBufFlux}.
 	 *
 	 * @param source publisher to decorate
 	 * @return a {@link ByteBufFlux}
@@ -83,7 +83,7 @@ public static ByteBufFlux fromString(Publisher<? extends String> source) {
 	}
 
 	/**
-	 * Decorate as {@link ByteBufFlux}
+	 * Decorate as {@link ByteBufFlux}.
 	 *
 	 * @param source publisher to decorate
 	 * @param charset the encoding charset
@@ -105,7 +105,7 @@ public static ByteBufFlux fromString(Publisher<? extends String> source, Charset
 	/**
 	 * Open a {@link java.nio.channels.FileChannel} from a path and stream
 	 * {@link ByteBuf} chunks with a default maximum size of 500K into
-	 * the returned {@link ByteBufFlux}
+	 * the returned {@link ByteBufFlux}.
 	 *
 	 * @param path the path to the resource to stream
 	 *
@@ -117,7 +117,7 @@ public static ByteBufFlux fromPath(Path path) {
 
 	/**
 	 * Open a {@link java.nio.channels.FileChannel} from a path and stream
-	 * {@link ByteBuf} chunks with a given maximum size into the returned {@link ByteBufFlux}
+	 * {@link ByteBuf} chunks with a given maximum size into the returned {@link ByteBufFlux}.
 	 *
 	 * @param path the path to the resource to stream
 	 * @param maxChunkSize the maximum per-item ByteBuf size
@@ -185,7 +185,7 @@ public static ByteBufFlux fromPath(Path path,
 	}
 
 	/**
-	 * Convert to a {@link ByteBuffer} inbound {@link Flux}
+	 * Convert to a {@link ByteBuffer} inbound {@link Flux}.
 	 *
 	 * @return a {@link ByteBuffer} inbound {@link Flux}
 	 */
@@ -201,7 +201,7 @@ public final Flux<ByteBuffer> asByteBuffer() {
 	}
 
 	/**
-	 * Convert to a {@literal byte[]} inbound {@link Flux}
+	 * Convert to a {@literal byte[]} inbound {@link Flux}.
 	 *
 	 * @return a {@literal byte[]} inbound {@link Flux}
 	 */
@@ -348,7 +348,7 @@ static ByteBufFlux maybeFuse(Flux<ByteBuf> source, ByteBufAllocator allocator) {
 	}
 
 	/**
-	 * A channel object to {@link ByteBuf} transformer
+	 * A channel object to {@link ByteBuf} transformer.
 	 */
 	static final Function<Object, ByteBuf> bytebufExtractor = o -> {
 		if (o instanceof ByteBuf) {

diff --git a/reactor-netty-core/src/main/java/reactor/netty/ByteBufMono.java b/reactor-netty-core/src/main/java/reactor/netty/ByteBufMono.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2011-2021 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2011-2023 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.
@@ -42,7 +42,7 @@
 public class ByteBufMono extends MonoOperator<ByteBuf, ByteBuf> {
 
 	/**
-	 * a {@link ByteBuffer} inbound {@link Mono}
+	 * a {@link ByteBuffer} inbound {@link Mono}.
 	 *
 	 * @return a {@link ByteBuffer} inbound {@link Mono}
 	 */
@@ -58,7 +58,7 @@ public final Mono<ByteBuffer> asByteBuffer() {
 	}
 
 	/**
-	 * a {@literal byte[]} inbound {@link Mono}
+	 * a {@literal byte[]} inbound {@link Mono}.
 	 *
 	 * @return a {@literal byte[]} inbound {@link Mono}
 	 */
@@ -76,7 +76,7 @@ public final Mono<byte[]> asByteArray() {
 	}
 
 	/**
-	 * a {@link String} inbound {@link Mono}
+	 * a {@link String} inbound {@link Mono}.
 	 *
 	 * @return a {@link String} inbound {@link Mono}
 	 */
@@ -85,7 +85,7 @@ public final Mono<String> asString() {
 	}
 
 	/**
-	 * a {@link String} inbound {@link Mono}
+	 * a {@link String} inbound {@link Mono}.
 	 *
 	 * @param charset the decoding charset
 	 *
@@ -124,7 +124,7 @@ public final Mono<InputStream> asInputStream() {
 	}
 
 	/**
-	 * Decorate as {@link ByteBufMono}
+	 * Decorate as {@link ByteBufMono}.
 	 *
 	 * @param source publisher to decorate
 	 * @return a {@link ByteBufMono}
@@ -134,7 +134,7 @@ public static ByteBufMono fromString(Publisher<? extends String> source) {
 	}
 
 	/**
-	 * Decorate as {@link ByteBufMono}
+	 * Decorate as {@link ByteBufMono}.
 	 *
 	 * @param source publisher to decorate
 	 * @param charset the encoding charset

diff --git a/reactor-netty-core/src/main/java/reactor/netty/ChannelBindException.java b/reactor-netty-core/src/main/java/reactor/netty/ChannelBindException.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2018-2021 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2018-2023 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.
@@ -23,14 +23,14 @@
 import reactor.util.annotation.Nullable;
 
 /**
- * Represents a failing attempt to bind a local socket address
+ * Represents a failing attempt to bind a local socket address.
  *
  * @author Stephane Maldini
  */
 public class ChannelBindException extends RuntimeException {
 
 	/**
-	 * Build a {@link ChannelBindException}
+	 * Build a {@link ChannelBindException}.
 	 *
 	 * @param bindAddress the local address
 	 * @param cause the root cause
@@ -76,7 +76,7 @@ public synchronized Throwable fillInStackTrace() {
 	}
 
 	/**
-	 * Return the configured binding host
+	 * Return the configured binding host.
 	 *
 	 * @return the configured binding host
 	 */
@@ -85,7 +85,7 @@ public String localHost() {
 	}
 
 	/**
-	 * Return the configured binding port
+	 * Return the configured binding port.
 	 *
 	 * @return the configured local binding port
 	 */

diff --git a/reactor-netty-core/src/main/java/reactor/netty/ChannelPipelineConfigurer.java b/reactor-netty-core/src/main/java/reactor/netty/ChannelPipelineConfigurer.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2020-2021 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2020-2023 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.
@@ -32,7 +32,7 @@
 public interface ChannelPipelineConfigurer {
 
 	/**
-	 * Return a noop configurer
+	 * Return a noop configurer.
 	 *
 	 * @return a noop configurer
 	 */
@@ -50,7 +50,7 @@ static ChannelPipelineConfigurer emptyConfigurer() {
 	void onChannelInit(ConnectionObserver connectionObserver, Channel channel, @Nullable SocketAddress remoteAddress);
 
 	/**
-	 * Chain together another {@link ChannelPipelineConfigurer}
+	 * Chain together another {@link ChannelPipelineConfigurer}.
 	 *
 	 * @param other the next {@link ChannelPipelineConfigurer}
 	 *

diff --git a/reactor-netty-core/src/main/java/reactor/netty/Connection.java b/reactor-netty-core/src/main/java/reactor/netty/Connection.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2011-2022 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2011-2023 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.
@@ -25,7 +25,7 @@
 import static java.util.Objects.requireNonNull;
 
 /**
- * Hold contextual information for the underlying {@link Channel}
+ * Hold contextual information for the underlying {@link Channel}.
  *
  * @author Stephane Maldini
  * @since 0.8
@@ -34,7 +34,7 @@
 public interface Connection extends DisposableChannel {
 
 	/**
-	 * Return an existing {@link Connection} wrapper or create a simple new one
+	 * Return an existing {@link Connection} wrapper or create a simple new one.
 	 *
 	 * @param channel channel to retrieve the connection reference from
 	 *
@@ -345,7 +345,7 @@ default boolean rebind(@Nullable Connection connection) {
 	}
 
 	/**
-	 * Remove a named handler if present and return this context
+	 * Remove a named handler if present and return this context.
 	 *
 	 * @param name handler name
 	 *

diff --git a/reactor-netty-core/src/main/java/reactor/netty/ConnectionObserver.java b/reactor-netty-core/src/main/java/reactor/netty/ConnectionObserver.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2018-2021 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2018-2023 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.
@@ -33,7 +33,7 @@
 public interface ConnectionObserver {
 
 	/**
-	 * Return a noop connection listener
+	 * Return a noop connection listener.
 	 *
 	 * @return a noop connection listener
 	 */
@@ -42,7 +42,7 @@ static ConnectionObserver emptyListener() {
 	}
 
 	/**
-	 * Connection listener {@link Context}
+	 * Connection listener {@link Context}.
 	 *
 	 * @return current {@link Context} or {@link Context#empty()}
 	 */
@@ -63,15 +63,15 @@ default void onUncaughtException(Connection connection, Throwable error) {
 	}
 
 	/**
-	 * React on connection state change (e.g. http request or response)
+	 * React on connection state change (e.g. http request or response).
 	 *
 	 * @param connection the connection reference
 	 * @param newState the new State
 	 */
 	void onStateChange(Connection connection, State newState);
 
 	/**
-	 * Chain together another {@link ConnectionObserver}
+	 * Chain together another {@link ConnectionObserver}.
 	 *
 	 * @param other the next {@link ConnectionObserver}
 	 *

diff --git a/reactor-netty-core/src/main/java/reactor/netty/DisposableChannel.java b/reactor-netty-core/src/main/java/reactor/netty/DisposableChannel.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2017-2021 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2017-2023 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.
@@ -29,7 +29,7 @@
 
 /**
  * Holds contextual information for the underlying channel and provides
- * non-blocking resource disposing API
+ * non-blocking resource disposing API.
  *
  * @author Stephane Maldini
  * @since 0.7
@@ -63,7 +63,7 @@ default SocketAddress address() {
 	Channel channel();
 
 	/**
-	 * Releases or closes the underlying {@link Channel}
+	 * Releases or closes the underlying {@link Channel}.
 	 */
 	@Override
 	@SuppressWarnings({"FutureReturnValueIgnored", "FunctionalInterfaceMethodChanged"})
@@ -107,7 +107,7 @@ default void disposeNow(Duration timeout) {
 	}
 
 	/**
-	 * Returns a {@link CoreSubscriber} that will dispose on complete or error
+	 * Returns a {@link CoreSubscriber} that will dispose on complete or error.
 	 */
 	default CoreSubscriber<Void> disposeSubscriber() {
 		return new ReactorNetty.ChannelDisposer(this);

diff --git a/reactor-netty-core/src/main/java/reactor/netty/DisposableServer.java b/reactor-netty-core/src/main/java/reactor/netty/DisposableServer.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2017-2021 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2017-2023 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.
@@ -19,7 +19,7 @@
 import java.net.SocketAddress;
 
 /**
- * Holds contextual information for the underlying server
+ * Holds contextual information for the underlying server.
  *
  * @author Stephane Maldini
  * @author Violeta Georgieva