|
|
|
@ -63,7 +63,7 @@ public class WebSocketIntegrationTests extends AbstractWebSocketIntegrationTests |
|
|
|
Flux<String> input = Flux.range(1, count).map(index -> "msg-" + index); |
|
|
|
Flux<String> input = Flux.range(1, count).map(index -> "msg-" + index); |
|
|
|
ReplayProcessor<Object> output = ReplayProcessor.create(count); |
|
|
|
ReplayProcessor<Object> output = ReplayProcessor.create(count); |
|
|
|
|
|
|
|
|
|
|
|
client.execute(getUrl("/echo"), |
|
|
|
this.client.execute(getUrl("/echo"), |
|
|
|
session -> { |
|
|
|
session -> { |
|
|
|
logger.debug("Starting to send messages"); |
|
|
|
logger.debug("Starting to send messages"); |
|
|
|
return session |
|
|
|
return session |
|
|
|
@ -87,7 +87,7 @@ public class WebSocketIntegrationTests extends AbstractWebSocketIntegrationTests |
|
|
|
AtomicReference<HandshakeInfo> infoRef = new AtomicReference<>(); |
|
|
|
AtomicReference<HandshakeInfo> infoRef = new AtomicReference<>(); |
|
|
|
MonoProcessor<Object> output = MonoProcessor.create(); |
|
|
|
MonoProcessor<Object> output = MonoProcessor.create(); |
|
|
|
|
|
|
|
|
|
|
|
client.execute(getUrl("/sub-protocol"), |
|
|
|
this.client.execute(getUrl("/sub-protocol"), |
|
|
|
new WebSocketHandler() { |
|
|
|
new WebSocketHandler() { |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public List<String> getSubProtocols() { |
|
|
|
public List<String> getSubProtocols() { |
|
|
|
@ -117,7 +117,7 @@ public class WebSocketIntegrationTests extends AbstractWebSocketIntegrationTests |
|
|
|
headers.add("my-header", "my-value"); |
|
|
|
headers.add("my-header", "my-value"); |
|
|
|
MonoProcessor<Object> output = MonoProcessor.create(); |
|
|
|
MonoProcessor<Object> output = MonoProcessor.create(); |
|
|
|
|
|
|
|
|
|
|
|
client.execute(getUrl("/custom-header"), headers, |
|
|
|
this.client.execute(getUrl("/custom-header"), headers, |
|
|
|
session -> session.receive() |
|
|
|
session -> session.receive() |
|
|
|
.map(WebSocketMessage::getPayloadAsText) |
|
|
|
.map(WebSocketMessage::getPayloadAsText) |
|
|
|
.subscribeWith(output) |
|
|
|
.subscribeWith(output) |
|
|
|
|