Work on iluwatar#74, increased coverage

Author: npathai

reactor/src/main/java/com/iluwatar/reactor/app/App.java

@@ -1,9 +1,12 @@
 package com.iluwatar.reactor.app;
 
 import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
 
 import com.iluwatar.reactor.framework.AbstractNioChannel;
 import com.iluwatar.reactor.framework.ChannelHandler;
+import com.iluwatar.reactor.framework.Dispatcher;
 import com.iluwatar.reactor.framework.NioDatagramChannel;
 import com.iluwatar.reactor.framework.NioReactor;
 import com.iluwatar.reactor.framework.NioServerSocketChannel;
@@ -64,26 +67,28 @@
 public class App {
 
   private NioReactor reactor;
+  private List<AbstractNioChannel> channels = new ArrayList<>();
 
   /**
    * App entry.
    * 
    * @throws IOException
    */
   public static void main(String[] args) throws IOException {
-    new App().start();
+    new App().start(new ThreadPoolDispatcher(2));
   }
 
   /**
    * Starts the NIO reactor.
+ * @param threadPoolDispatcher 
    * 
    * @throws IOException if any channel fails to bind.
    */
-  public void start() throws IOException {
+  public void start(Dispatcher dispatcher) throws IOException {
     /*
      * The application can customize its event dispatching mechanism.
      */
-    reactor = new NioReactor(new ThreadPoolDispatcher(2));
+    reactor = new NioReactor(dispatcher);
 
     /*
      * This represents application specific business logic that dispatcher will call on appropriate
@@ -103,20 +108,26 @@ public void start() throws IOException {
    * Stops the NIO reactor. This is a blocking call.
    * 
    * @throws InterruptedException if interrupted while stopping the reactor.
+   * @throws IOException if any I/O error occurs
    */
-  public void stop() throws InterruptedException {
+  public void stop() throws InterruptedException, IOException {
     reactor.stop();
+    for (AbstractNioChannel channel : channels) {
+    	channel.getChannel().close();
+    }
   }
 
-  private static AbstractNioChannel tcpChannel(int port, ChannelHandler handler) throws IOException {
+  private AbstractNioChannel tcpChannel(int port, ChannelHandler handler) throws IOException {
     NioServerSocketChannel channel = new NioServerSocketChannel(port, handler);
     channel.bind();
+    channels.add(channel);
     return channel;
   }
 
-  private static AbstractNioChannel udpChannel(int port, ChannelHandler handler) throws IOException {
+  private AbstractNioChannel udpChannel(int port, ChannelHandler handler) throws IOException {
     NioDatagramChannel channel = new NioDatagramChannel(port, handler);
     channel.bind();
+    channels.add(channel);
     return channel;
   }
 }

reactor/src/test/java/com/iluwatar/reactor/app/AppTest.java

@@ -4,6 +4,9 @@
 
 import org.junit.Test;
 
+import com.iluwatar.reactor.framework.SameThreadDispatcher;
+import com.iluwatar.reactor.framework.ThreadPoolDispatcher;
+
 /**
  * 
  * This class tests the Distributed Logging service by starting a Reactor and then sending it
@@ -14,15 +17,41 @@
 public class AppTest {
 
   /**
-   * Test the application.
+   * Test the application using pooled thread dispatcher.
+   * 
+   * @throws IOException if any I/O error occurs.
+   * @throws InterruptedException if interrupted while stopping the application.
+   */
+  @Test
+  public void testAppUsingThreadPoolDispatcher() throws IOException, InterruptedException {
+    App app = new App();
+    app.start(new ThreadPoolDispatcher(2));
+
+    AppClient client = new AppClient();
+    client.start();
+
+    // allow clients to send requests. Artificial delay.
+    try {
+      Thread.sleep(2000);
+    } catch (InterruptedException e) {
+      e.printStackTrace();
+    }
+
+    client.stop();
+
+    app.stop();
+  }
+  
+  /**
+   * Test the application using same thread dispatcher.
    * 
    * @throws IOException if any I/O error occurs.
    * @throws InterruptedException if interrupted while stopping the application.
    */
   @Test
-  public void testApp() throws IOException, InterruptedException {
+  public void testAppUsingSameThreadDispatcher() throws IOException, InterruptedException {
     App app = new App();
-    app.start();
+    app.start(new SameThreadDispatcher());
 
     AppClient client = new AppClient();
     client.start();