From 65e1cae2decfc1b86481eb40607eac0e23b64b0c Mon Sep 17 00:00:00 2001 From: MottoX Date: Wed, 11 Apr 2018 16:11:37 +0800 Subject: [PATCH] Cleanup unnecessary code --- .../main/java/com/iluwatar/reactor/framework/NioReactor.java | 5 +---- .../iluwatar/reactor/framework/NioServerSocketChannel.java | 4 ++-- 2 files changed, 3 insertions(+), 6 deletions(-) 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); }