reactived test case and corrected ObjectProducer's behavior

src/main/java/teetime/stage/ObjectProducer.java

@@ -54,14 +54,11 @@ public final class ObjectProducer<T> extends AbstractProducerStage<T> {
 
 	@Override
 	protected void execute() {
+		for (int i = 0; i < numInputObjects; i++) {
 			T newObject = this.inputObjectCreator.create();
-		this.numInputObjects--;
-
 			outputPort.send(newObject);
-
-		if (this.numInputObjects == 0) {
-			this.terminate();
 		}
+		this.terminate();
 	}
 
 }

src/test/java/teetime/stage/ObjectProducerTest.java

@@ -43,6 +43,7 @@ public class ObjectProducerTest {
 		assertThat(results, contains(1, 2, 3));
 	}
 
+	@Test
 	public void producerShouldSendNothingIfSpecified() {
 		final List<Integer> results = new ArrayList<Integer>();
 		final ObjectProducer<Integer> producer = new ObjectProducer<Integer>(0, new Generator());