### Question:
TcpSocketServer { public void close() { queue.execute(new Runnable() { @Override public void run() { disconnect(currentServerChannel, currentAcceptSelectionKey, null); } }); } TcpSocketServer(Ninio ninio); TcpSocketServer bind(Address bindAddress); CompletableFuture<Void> listen(); CompletableFuture<TcpSocket> accept(); void close();  }### Answer:
@Test public void testAbruptlyClosing() throws Exception { test(new WayOfClosing() { @Override public void doClose(TcpSocket socket) { socket.close(); } }); }