From 2961d61c068e55b470228fc35b767cce04b2efe1 Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Mon, 20 Apr 2015 15:57:20 +0200
Subject: [PATCH] minor refactoring
---
src/main/java/teetime/stage/io/EveryXthPrinter.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/src/main/java/teetime/stage/io/EveryXthPrinter.java b/src/main/java/teetime/stage/io/EveryXthPrinter.java
index 1ca83ce5..c074dfd5 100644
--- a/src/main/java/teetime/stage/io/EveryXthPrinter.java
+++ b/src/main/java/teetime/stage/io/EveryXthPrinter.java
@@ -32,7 +32,7 @@ public final class EveryXthPrinter<T> extends AbstractCompositeStage {
private final List<Stage> lastStages = new ArrayList<Stage>();
public EveryXthPrinter(final int threshold) {
- distributor = new Distributor<T>();
+ distributor = new Distributor<T>(new CopyByReferenceStrategy());
EveryXthStage<T> everyXthStage = new EveryXthStage<T>(threshold);
Printer<Integer> printer = new Printer<Integer>();
@@ -40,7 +40,6 @@ public final class EveryXthPrinter<T> extends AbstractCompositeStage {
connectPorts(everyXthStage.getOutputPort(), printer.getInputPort());
lastStages.add(printer);
- distributor.setStrategy(new CopyByReferenceStrategy());
}
public InputPort<T> getInputPort() {
--
GitLab