@Test
public void clientCanConnectToAServer() throws Exception {
- var client = new Client("localhost", server.getPort());
client.connect();
server.connect().get();
}
@Test
public void listenerIsNotifiedOnConnectEvent() throws Exception {
- var client = new Client("localhost", server.getPort());
var connectListenerCalled = new AtomicBoolean(false);
client.onConnect(() -> connectListenerCalled.set(true));
client.connect();
@Test
public void clientCanSendCommandToServer() throws Exception {
- var client = new Client("localhost", server.getPort());
client.connect();
server.connect().get();
server.writeLine("{\"event\": \"connected\"}");
}
private final FakeTcpServer server = new FakeTcpServer(Executors.newCachedThreadPool());
+ private final Client client = new Client("localhost", server.getPort());
}