Skip to content
This repository was archived by the owner on Jun 21, 2023. It is now read-only.

Commit 87c9ecc

Browse files
committed
Added WebsocketServerTest, updated WebsocketClientTest
1 parent 8a2404c commit 87c9ecc

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

services-gateway-tests/src/test/java/io/scalecube/services/gateway/websocket/WebsocketClientTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ void testMessageSequence() {
9898
.transport(new GatewayClientTransport(client))
9999
.router(new StaticAddressRouter(gatewayAddress));
100100

101-
int count = ThreadLocalRandom.current().nextInt(1042) + 24;
101+
int count = ThreadLocalRandom.current().nextInt(100, 1042) + 24;
102102

103103
StepVerifier.create(serviceCall.api(TestService.class).many(count) /*.log("<<< ")*/)
104104
.expectNextSequence(IntStream.range(0, count).boxed().collect(Collectors.toList()))

services-gateway-tests/src/test/java/io/scalecube/services/gateway/websocket/WebsocketServerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ void testMessageSequence() {
8383
.transport(new GatewayClientTransport(client))
8484
.router(new StaticAddressRouter(gatewayAddress));
8585

86-
int count = ThreadLocalRandom.current().nextInt(1042) + 24;
86+
int count = ThreadLocalRandom.current().nextInt(100, 1042) + 24;
8787

8888
StepVerifier.create(serviceCall.api(TestService.class).many(count) /*.log("<<< ")*/)
8989
.expectNextSequence(IntStream.range(0, count).boxed().collect(Collectors.toList()))

0 commit comments

Comments
 (0)