modified scope of pipes and added test for add method

src/main/java/teetime/framework/pipe/CommittablePipe.java

@@ -20,7 +20,7 @@ import teetime.framework.InputPort;
 import teetime.framework.OutputPort;
 import teetime.util.list.CommittableResizableArrayQueue;
 
-public final class CommittablePipe extends AbstractIntraThreadPipe {
+final class CommittablePipe extends AbstractIntraThreadPipe {
 
 	private final CommittableResizableArrayQueue<Object> elements = new CommittableResizableArrayQueue<Object>(null, 4);
 

src/main/java/teetime/framework/pipe/ConcurrentBlockingIntraThreadPipe.java

@@ -21,7 +21,7 @@ import teetime.framework.AbstractIntraThreadPipe;
 import teetime.framework.InputPort;
 import teetime.framework.OutputPort;
 
-public final class ConcurrentBlockingIntraThreadPipe<T> extends AbstractIntraThreadPipe {
+final class ConcurrentBlockingIntraThreadPipe<T> extends AbstractIntraThreadPipe {
 
 	private final ConcurrentLinkedQueue<Object> queue;
 

src/main/java/teetime/framework/pipe/OrderedGrowableArrayPipe.java

@@ -20,7 +20,7 @@ import teetime.framework.InputPort;
 import teetime.framework.OutputPort;
 import teetime.util.concurrent.workstealing.CircularArray;
 
-public final class OrderedGrowableArrayPipe extends AbstractIntraThreadPipe {
+final class OrderedGrowableArrayPipe extends AbstractIntraThreadPipe {
 
 	private final CircularArray<Object> elements;
 	private int head;

src/main/java/teetime/framework/pipe/OrderedGrowablePipe.java

@@ -21,7 +21,7 @@ import teetime.framework.AbstractIntraThreadPipe;
 import teetime.framework.InputPort;
 import teetime.framework.OutputPort;
 
-public class OrderedGrowablePipe extends AbstractIntraThreadPipe {
+class OrderedGrowablePipe extends AbstractIntraThreadPipe {
 
 	private final LinkedList<Object> elements;
 

src/main/java/teetime/framework/pipe/RelayTestPipe.java

@@ -18,7 +18,7 @@ package teetime.framework.pipe;
 import teetime.framework.AbstractInterThreadPipe;
 import teetime.util.ConstructorClosure;
 
-public final class RelayTestPipe<T> extends AbstractInterThreadPipe {
+final class RelayTestPipe<T> extends AbstractInterThreadPipe {
 
 	private int numInputObjects;
 	private final ConstructorClosure<T> inputObjectCreator;

src/main/java/teetime/framework/pipe/SingleElementPipe.java

@@ -19,7 +19,7 @@ import teetime.framework.AbstractIntraThreadPipe;
 import teetime.framework.InputPort;
 import teetime.framework.OutputPort;
 
-public final class SingleElementPipe extends AbstractIntraThreadPipe {
+final class SingleElementPipe extends AbstractIntraThreadPipe {
 
 	private Object element;
 

src/main/java/teetime/framework/pipe/SpScIntraThreadPipe.java

@@ -31,7 +31,7 @@ import teetime.framework.OutputPort;
  *
  * @param <T>
  */
-public final class SpScIntraThreadPipe<T> extends AbstractIntraThreadPipe {
+final class SpScIntraThreadPipe<T> extends AbstractIntraThreadPipe {
 
 	private final Queue<Object> queue;
 

src/main/java/teetime/framework/pipe/SpScPipe.java

@@ -21,7 +21,7 @@ import teetime.framework.OutputPort;
 import teetime.framework.StageState;
 import teetime.util.concurrent.queue.ObservableSpScArrayQueue;
 
-public final class SpScPipe extends AbstractInterThreadPipe implements IMonitorablePipe {
+final class SpScPipe extends AbstractInterThreadPipe implements IMonitorablePipe {
 
 	// private static final Logger LOGGER = LoggerFactory.getLogger(SpScPipe.class);
 

src/main/java/teetime/framework/pipe/UnboundedSpScPipe.java

@@ -26,7 +26,7 @@ import teetime.framework.AbstractInterThreadPipe;
 import teetime.framework.InputPort;
 import teetime.framework.OutputPort;
 
-public final class UnboundedSpScPipe extends AbstractInterThreadPipe {
+final class UnboundedSpScPipe extends AbstractInterThreadPipe {
 
 	private final Queue<Object> queue;
 

src/main/java/teetime/framework/pipe/UnorderedGrowablePipe.java

@@ -19,7 +19,7 @@ import teetime.framework.AbstractIntraThreadPipe;
 import teetime.framework.InputPort;
 import teetime.framework.OutputPort;
 
-public final class UnorderedGrowablePipe extends AbstractIntraThreadPipe {
+final class UnorderedGrowablePipe extends AbstractIntraThreadPipe {
 
 	private Object[] elements;
 	// private final ArrayWrapper2<T> elements = new ArrayWrapper2<T>(2);

src/test/java/teetime/framework/pipe/SpScPipeTest.java

@@ -15,9 +15,13 @@
  */
 package teetime.framework.pipe;
 
+import static org.junit.Assert.assertFalse;
+
 import java.util.ArrayList;
 import java.util.List;
 
+import org.junit.Test;
+
 import teetime.framework.AbstractInterThreadPipe;
 import teetime.framework.InputPort;
 import teetime.framework.OutputPort;
@@ -61,4 +65,10 @@ public class SpScPipeTest {
 		}
 		// Assert.assertEquals(list, secondList);
 	}
+
+	@Test(expected = NullPointerException.class)
+	public void testAdd() throws Exception {
+		SpScPipe pipe = new SpScPipe(null, null, 4);
+		assertFalse(pipe.add(null));
+	}
 }