From bd5678e5ca02e6a6dfab513c538daf0a027b9265 Mon Sep 17 00:00:00 2001
From: Nelson Tavares de Sousa <ntd@informatik.uni-kiel.de>
Date: Fri, 20 Feb 2015 15:17:04 +0100
Subject: [PATCH] IterableProducer terminates now
---
src/main/java/teetime/stage/IterableProducer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/src/main/java/teetime/stage/IterableProducer.java b/src/main/java/teetime/stage/IterableProducer.java
index 3f85021a..9e8eb9d4 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) {
--
GitLab