SpringCloud/spring-cloud-gateway
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix java 11 compile

Browse Source
This commit is contained in:
Spencer Gibb
2018-10-17 22:35:54 -04:00
parent 5d76667f9b
commit 6048143da1
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-gateway-core/src/test/java/org/springframework/cloud/gateway/test/websocket/WebSocketIntegrationTests.java
View File

@@ -196,7 +196,7 @@ public class WebSocketIntegrationTests {
session -> {
logger.debug("Starting to send messages");
return session
.send(input.doOnNext(s -> logger.debug("outbound " + s)).map(session::textMessage))
.send(input.doOnNext(s -> logger.debug("outbound " + s)).map(s -> session.textMessage(s)))
.thenMany(session.receive().take(count).map(WebSocketMessage::getPayloadAsText))
.subscribeWith(output)
.doOnNext(s -> logger.debug("inbound " + s))
@@ -220,7 +220,7 @@ public class WebSocketIntegrationTests {
session -> {
logger.debug("Starting to send messages");
return session
.send(input.doOnNext(s -> logger.debug("outbound " + s)).map(session::textMessage))
.send(input.doOnNext(s -> logger.debug("outbound " + s)).map(s -> session.textMessage(s)))
.thenMany(session.receive().take(count).map(WebSocketMessage::getPayloadAsText))
.subscribeWith(output)
.doOnNext(s -> logger.debug("inbound " + s))