Skip to content
Snippets Groups Projects
Commit 74b2e0df authored by Christian Wulf's avatar Christian Wulf
Browse files

minor refactorings for InitialElementProducer

parent 0dd9f203
No related branches found
No related tags found
No related merge requests found
#FindBugs User Preferences
#Mon Apr 20 15:07:50 CEST 2015
#Tue Apr 21 14:08:24 CEST 2015
detector_threshold=3
effort=max
excludefilter0=.fbExcludeFilterFile|true
......
......@@ -22,38 +22,38 @@ import teetime.framework.AbstractProducerStage;
public final class InitialElementProducer<T> extends AbstractProducerStage<T> {
private Iterable<T> iter;
private Iterable<T> elements;
public InitialElementProducer(final T... elements) {
this.iter = Arrays.asList(elements);
this.elements = Arrays.asList(elements);
}
public <O extends Iterable<T>> InitialElementProducer(final O iter) {
this.iter = iter;
public <O extends Iterable<T>> InitialElementProducer(final O elements) {
this.elements = elements;
}
@Override
public void onStarting() throws Exception {
if (elements == null) {
throw new IllegalArgumentException("The given iterable must not be null");
}
super.onStarting();
}
@Override
protected void execute() {
for (final T i : this.iter) {
this.outputPort.send(i);
for (final T element : this.elements) {
this.outputPort.send(element);
}
this.terminate();
}
public void setIter(final Iterable<T> iter) {
this.iter = iter;
public void setIter(final Iterable<T> elements) {
this.elements = elements;
}
public void setIter(final T... elements) {
this.iter = Arrays.asList(elements);
}
@Override
public void onStarting() throws Exception {
if (iter == null) {
throw new IllegalArgumentException("iter must not be null");
}
super.onStarting();
this.elements = Arrays.asList(elements);
}
public static void main(final String[] args) {
......
wiki @ 0e447457
Subproject commit 162510ff4d2f04011498ba6920aae0c78347c6c8
Subproject commit 0e4474577e1f49bc96e734c286b2d9e0363895e8
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