Skip to content
Snippets Groups Projects
Commit bd5678e5 authored by Nelson Tavares de Sousa's avatar Nelson Tavares de Sousa
Browse files

IterableProducer terminates now

parent e01218ed
No related branches found
No related tags found
No related merge requests found
...@@ -30,7 +30,7 @@ public final class IterableProducer<T> extends AbstractProducerStage<T> { ...@@ -30,7 +30,7 @@ public final class IterableProducer<T> extends AbstractProducerStage<T> {
for (final T i : this.iter) { for (final T i : this.iter) {
this.outputPort.send(i); this.outputPort.send(i);
} }
this.terminate();
} }
public void setIter(final Iterable<T> iter) { public void setIter(final Iterable<T> iter) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment