diff --git a/src/main/java/teetime/stage/IterableProducer.java b/src/main/java/teetime/stage/IterableProducer.java index 3f85021ac9ae88710ac153124c659ca51e81f5ef..9e8eb9d42aef42fb7fdf70efd0145244a5fa350b 100644 --- a/src/main/java/teetime/stage/IterableProducer.java +++ b/src/main/java/teetime/stage/IterableProducer.java @@ -30,7 +30,7 @@ public final class IterableProducer<T> extends AbstractProducerStage<T> { for (final T i : this.iter) { this.outputPort.send(i); } - + this.terminate(); } public void setIter(final Iterable<T> iter) {