moving module

felipeazv · felipeazv · commit a25ea6372a08 · 2018-01-18T13:40:33.000+01:00
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
@@ -13,7 +13,7 @@
 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())
