root
/
spring-framework
mirror of https://github.com/spring-projects/spring-framework.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Polishing

This commit is contained in:
Sam Brannen 2019-06-05 14:41:14 +03:00
parent 2ed9a61ba0
commit 1259b7cb49
1 changed files with 10 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
spring-websocket/src/test/java/org/springframework/web/socket/handler/ConcurrentWebSocketSessionDecoratorTests.java
View File

@ -66,7 +66,7 @@ public class ConcurrentWebSocketSessionDecoratorTests {
BlockingSession session = new BlockingSession();
session.setOpen(true);
final ConcurrentWebSocketSessionDecorator decorator =
ConcurrentWebSocketSessionDecorator decorator =
new ConcurrentWebSocketSessionDecorator(session, 10 * 1000, 1024);
sendBlockingMessage(decorator);
@ -91,7 +91,7 @@ public class ConcurrentWebSocketSessionDecoratorTests {
session.setId("123");
session.setOpen(true);
final ConcurrentWebSocketSessionDecorator decorator =
ConcurrentWebSocketSessionDecorator decorator =
new ConcurrentWebSocketSessionDecorator(session, 100, 1024);
sendBlockingMessage(decorator);
@ -113,17 +113,13 @@ public class ConcurrentWebSocketSessionDecoratorTests {
session.setId("123");
session.setOpen(true);
final ConcurrentWebSocketSessionDecorator decorator =
ConcurrentWebSocketSessionDecorator decorator =
new ConcurrentWebSocketSessionDecorator(session, 10*1000, 1024);
sendBlockingMessage(decorator);
StringBuilder sb = new StringBuilder();
for (int i = 0 ; i < 1023; i++) {
sb.append("a");
}
TextMessage message = new TextMessage(sb.toString());
String msg = String.format("%1023s", "a");
TextMessage message = new TextMessage(msg);
decorator.sendMessage(message);
assertThat(decorator.getBufferSize()).isEqualTo(1023);
@ -142,24 +138,20 @@ public class ConcurrentWebSocketSessionDecoratorTests {
session.setId("123");
session.setOpen(true);
final ConcurrentWebSocketSessionDecorator decorator =
ConcurrentWebSocketSessionDecorator decorator =
new ConcurrentWebSocketSessionDecorator(session, 10*1000, 1024, OverflowStrategy.DROP);
sendBlockingMessage(decorator);
StringBuilder sb = new StringBuilder();
for (int i = 0 ; i < 1023; i++) {
sb.append("a");
}
String msg = String.format("%1023s", "a");
for (int i=0; i < 5; i++) {
TextMessage message = new TextMessage(sb.toString());
for (int i = 0; i < 5; i++) {
TextMessage message = new TextMessage(msg);
decorator.sendMessage(message);
}
assertThat(decorator.getBufferSize()).isEqualTo(1023);
assertThat(session.isOpen()).isTrue();
}
@Test
@ -187,7 +179,7 @@ public class ConcurrentWebSocketSessionDecoratorTests {
int sendTimeLimit = 100;
int bufferSizeLimit = 1024;
final ConcurrentWebSocketSessionDecorator decorator =
ConcurrentWebSocketSessionDecorator decorator =
new ConcurrentWebSocketSessionDecorator(session, sendTimeLimit, bufferSizeLimit);
Executors.newSingleThreadExecutor().submit((Runnable) () -> {