From a25ea6372a080c56cc49cc2ea0be73a7a801c605 Mon Sep 17 00:00:00 2001
From: felipeazv <felipe.azv@gmail.com>
Date: Thu, 18 Jan 2018 13:40:33 +0100
Subject: [PATCH] moving module

---
 .../reactive/websocket/ReactiveJavaClientWebSocket.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/spring-5-reactive/src/main/java/com/baeldung/reactive/websocket/ReactiveJavaClientWebSocket.java b/spring-5-reactive/src/main/java/com/baeldung/reactive/websocket/ReactiveJavaClientWebSocket.java
index 3e25e2a29c..74e2d7daca 100644
--- a/spring-5-reactive/src/main/java/com/baeldung/reactive/websocket/ReactiveJavaClientWebSocket.java
+++ b/spring-5-reactive/src/main/java/com/baeldung/reactive/websocket/ReactiveJavaClientWebSocket.java
@@ -13,7 +13,7 @@ import reactor.core.publisher.Mono;
 public class ReactiveJavaClientWebSocket {
     public static void main(String[] args) throws InterruptedException {
         WebSocketClient client = new ReactorNettyWebSocketClient();
-        client.execute(URI.create("ws://localhost:8080/event-emitter"), session -> session.send(Mono.just(session.textMessage("event-me-from-spring-reactive-client")))
+        client.execute(URI.create("ws://localhost:8080/event-emitter"), session ->  session.send(Mono.just(session.textMessage("event-me-from-spring-reactive-client")))
             .thenMany(session.receive()
                 .map(WebSocketMessage::getPayloadAsText)
                 .log())