diff --git a/reactor/src/main/java/com/iluwatar/reactor/framework/NioReactor.java b/reactor/src/main/java/com/iluwatar/reactor/framework/NioReactor.java index a315389a3..7fcffa0ac 100644 --- a/reactor/src/main/java/com/iluwatar/reactor/framework/NioReactor.java +++ b/reactor/src/main/java/com/iluwatar/reactor/framework/NioReactor.java @@ -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..."); diff --git a/reactor/src/main/java/com/iluwatar/reactor/framework/NioServerSocketChannel.java b/reactor/src/main/java/com/iluwatar/reactor/framework/NioServerSocketChannel.java index 4721d292a..1d91c4eb7 100644 --- a/reactor/src/main/java/com/iluwatar/reactor/framework/NioServerSocketChannel.java +++ b/reactor/src/main/java/com/iluwatar/reactor/framework/NioServerSocketChannel.java @@ -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); }