gaspersic/java-design-patterns
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Merge pull request #743 from MottoX/cleanup

Browse Source 
Cleanup unnecessary code
This commit is contained in:
Ilkka Seppälä 2018-04-12 20:39:45 +03:00 committed by GitHub
commit 1e04b17a2d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
reactor/src/main/java/com/iluwatar/reactor/framework/NioReactor.java
View File

@ -84,11 +84,8 @@ public class NioReactor {
/** /**
* Starts the reactor event loop in a new thread. * 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(() -> { reactorMain.execute(() -> {
try { try {
LOGGER.info("Reactor started, waiting for events..."); LOGGER.info("Reactor started, waiting for events...");

4
reactor/src/main/java/com/iluwatar/reactor/framework/NioServerSocketChannel.java
View File

@ -98,9 +98,9 @@ public class NioServerSocketChannel extends AbstractNioChannel {
*/ */
@Override @Override
public void bind() throws IOException { public void bind() throws IOException {
((ServerSocketChannel) getJavaChannel()).socket().bind( getJavaChannel().socket().bind(
new InetSocketAddress(InetAddress.getLocalHost(), port)); new InetSocketAddress(InetAddress.getLocalHost(), port));
((ServerSocketChannel) getJavaChannel()).configureBlocking(false); getJavaChannel().configureBlocking(false);
LOGGER.info("Bound TCP socket at port: {}", port); LOGGER.info("Bound TCP socket at port: {}", port);
} }