use Matchers.equalTo instead of Matchers.is

Signed-off-by: Lachlan Roberts <lachlan@webtide.com>
This commit is contained in:
Lachlan Roberts 2021-11-12 21:37:15 +11:00
parent 750ee0a182
commit d8bcac7767
1 changed files with 5 additions and 5 deletions

View File

@ -32,7 +32,7 @@ import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.is;
import static org.hamcrest.Matchers.equalTo;
import static org.junit.jupiter.api.Assertions.assertTrue;
public class SingleMessageHandlerTest
@ -101,14 +101,14 @@ public class SingleMessageHandlerTest
// Can send/receive binary message successfully.
ByteBuffer binaryMessage = BufferUtil.toBuffer("hello world");
session.getBasicRemote().sendBinary(binaryMessage);
assertThat(BINARY_MESSAGES.poll(5, TimeUnit.SECONDS), is(binaryMessage));
assertThat(BINARY_MESSAGES.poll(5, TimeUnit.SECONDS), equalTo(binaryMessage));
// Text message is discarded by implementation.
session.getBasicRemote().sendText("hello world");
// Next binary message is still received.
session.getBasicRemote().sendBinary(binaryMessage);
assertThat(BINARY_MESSAGES.poll(5, TimeUnit.SECONDS), is(binaryMessage));
assertThat(BINARY_MESSAGES.poll(5, TimeUnit.SECONDS), equalTo(binaryMessage));
session.close();
assertTrue(eventSocket.closeLatch.await(5, TimeUnit.SECONDS));
@ -124,14 +124,14 @@ public class SingleMessageHandlerTest
// Can send/receive text message successfully.
String textMessage = "hello world";
session.getBasicRemote().sendText(textMessage);
assertThat(TEXT_MESSAGES.poll(5, TimeUnit.SECONDS), is(textMessage));
assertThat(TEXT_MESSAGES.poll(5, TimeUnit.SECONDS), equalTo(textMessage));
// Binary message is discarded by implementation.
session.getBasicRemote().sendBinary(BufferUtil.toBuffer("hello world"));
// Next text message is still received.
session.getBasicRemote().sendText(textMessage);
assertThat(TEXT_MESSAGES.poll(5, TimeUnit.SECONDS), is(textMessage));
assertThat(TEXT_MESSAGES.poll(5, TimeUnit.SECONDS), equalTo(textMessage));
session.close();
assertTrue(eventSocket.closeLatch.await(5, TimeUnit.SECONDS));