diff --git a/spring-webflux/src/main/java/org/springframework/web/reactive/socket/WebSocketHandler.java b/spring-webflux/src/main/java/org/springframework/web/reactive/socket/WebSocketHandler.java
index 32ae15599f..592e252cfe 100644
--- a/spring-webflux/src/main/java/org/springframework/web/reactive/socket/WebSocketHandler.java
+++ b/spring-webflux/src/main/java/org/springframework/web/reactive/socket/WebSocketHandler.java
@@ -44,7 +44,7 @@ import reactor.core.publisher.Mono;
  * 	@Override
  * 	public Mono<Void> handle(WebSocketSession session) {
  *
- * 		Flux<WebSocketMessage> input = session.receive()
+ * 		Flux<WebSocketMessage> output = session.receive()
  *			.doOnNext(message -> {
  * 				// ...
  * 			})
@@ -89,7 +89,7 @@ import reactor.core.publisher.Mono;
  * completion of that flow. That means there is no need to check if the
  * connection is open, since Reactive Streams signals will terminate activity.
  * The inbound stream receives a completion/error signal, and the outbound
- * stream receives receives a cancellation signal.
+ * stream receives a cancellation signal.
  *
  * @author Rossen Stoyanchev
  * @since 5.0