Cleanup unnecessary code
This commit is contained in:
		| @@ -84,11 +84,8 @@ public class NioReactor { | ||||
|  | ||||
|   /** | ||||
|    * Starts the reactor event loop in a new thread. | ||||
|    *  | ||||
|    * @throws IOException | ||||
|    *           if any I/O error occurs. | ||||
|    */ | ||||
|   public void start() throws IOException { | ||||
|   public void start() { | ||||
|     reactorMain.execute(() -> { | ||||
|       try { | ||||
|         LOGGER.info("Reactor started, waiting for events..."); | ||||
|   | ||||
| @@ -98,9 +98,9 @@ public class NioServerSocketChannel extends AbstractNioChannel { | ||||
|    */ | ||||
|   @Override | ||||
|   public void bind() throws IOException { | ||||
|     ((ServerSocketChannel) getJavaChannel()).socket().bind( | ||||
|     getJavaChannel().socket().bind( | ||||
|         new InetSocketAddress(InetAddress.getLocalHost(), port)); | ||||
|     ((ServerSocketChannel) getJavaChannel()).configureBlocking(false); | ||||
|     getJavaChannel().configureBlocking(false); | ||||
|     LOGGER.info("Bound TCP socket at port: {}", port); | ||||
|   } | ||||
|  | ||||
|   | ||||
		Reference in New Issue
	
	Block a user