return serverSocket.getLocalPort();
}
+ public void waitForNextScan() throws InterruptedException {
+ synchronized (this) {
+ wait();
+ }
+ }
+
private void scanForWindows() {
while (!closed.get()) {
var currentlyOpenWindows = stream(Window.getWindows()).filter(Component::isVisible).toList();
windows.put(newWindow.getName(), newWindow);
});
Thread.yield();
+ synchronized (this) {
+ notifyAll();
+ }
}
}
var window = new Window(null);
window.setVisible(true);
try {
- connectToServer(verifyConnectedEvent((reader, ready, writer) -> {
- assertTimeout(ready, Duration.of(1, ChronoUnit.SECONDS));
- }));
+ try (var server = new Server()) {
+ server.start();
+ server.waitForNextScan();
+ createConnection(server, verifyConnectedEvent((reader, ready, writer) -> {
+ assertTimeout(ready, Duration.of(1, ChronoUnit.SECONDS));
+ }));
+ }
} finally {
window.setVisible(false);
}