removed if in OutputPort

src/main/java/teetime/framework/OutputPort.java

@@ -25,18 +25,16 @@ public final class OutputPort<T> extends AbstractPort<T> {
 
 	/**
 	 * @param element
-	 *            to be sent
+	 *            to be sent; May not be <code>null</code>.
 	 */
 	public void send(final T element) {
-		if (this.pipe.add(element)) {
-			this.pipe.reportNewElement();
-		}
+		this.pipe.add(element);
 	}
 
 	/**
 	 *
 	 * @param signal
-	 *            to be sent
+	 *            to be sent; May not be <code>null</code>.
 	 */
 	public void sendSignal(final ISignal signal) {
 		this.pipe.sendSignal(signal);

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

@@ -36,6 +36,7 @@ public final class SingleElementPipe extends AbstractIntraThreadPipe {
 	@Override
 	public boolean add(final Object element) {
 		this.element = element;
+		this.reportNewElement();
 		return true;
 	}
 

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

@@ -53,6 +53,7 @@ public final class SpScPipe extends AbstractInterThreadPipe {
 			this.numWaits++;
 			Thread.yield();
 		}
+		// this.reportNewElement();
 		return true;
 	}