iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

moving module

This commit is contained in:
felipeazv 2018-01-18 13:40:33 +01:00
parent fe1105a526
commit a25ea6372a
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
spring-5-reactive/src/main/java/com/baeldung/reactive/websocket/ReactiveJavaClientWebSocket.java
View File

@ -13,7 +13,7 @@ import reactor.core.publisher.Mono;
public class ReactiveJavaClientWebSocket { public class ReactiveJavaClientWebSocket {
public static void main(String[] args) throws InterruptedException { public static void main(String[] args) throws InterruptedException {
WebSocketClient client = new ReactorNettyWebSocketClient(); 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() .thenMany(session.receive()
.map(WebSocketMessage::getPayloadAsText) .map(WebSocketMessage::getPayloadAsText)
.log()) .log())