From d5df097e0e3afe7ae36622ad275b39631ee38c3b Mon Sep 17 00:00:00 2001 From: xiexed Date: Mon, 2 Jul 2018 14:55:42 +0300 Subject: [PATCH] Small typo fixes in WebSocketHandler doc --- .../springframework/web/reactive/socket/WebSocketHandler.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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