From ca4cdb70334c62322fb0deb47e6343b6b40a8ac1 Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Thu, 19 Mar 2015 14:20:38 +0100
Subject: [PATCH] added javadoc
---
src/main/java/teetime/framework/OutputPort.java | 11 +++++++++++
.../teetime/stage/basic/distributor/Distributor.java | 2 +-
.../stage/basic/distributor/RoundRobinStrategy2.java | 4 ++--
3 files changed, 14 insertions(+), 3 deletions(-)
diff --git a/src/main/java/teetime/framework/OutputPort.java b/src/main/java/teetime/framework/OutputPort.java
index 904e567b..bbc69cf4 100644
--- a/src/main/java/teetime/framework/OutputPort.java
+++ b/src/main/java/teetime/framework/OutputPort.java
@@ -18,6 +18,15 @@ package teetime.framework;
import teetime.framework.signal.ISignal;
import teetime.framework.signal.TerminatingSignal;
+/**
+ *
+ * @author Christian Wulf
+ *
+ * @param <T>
+ * the type of elements to be sent
+ *
+ * @since 1.0
+ */
public final class OutputPort<T> extends AbstractPort<T> {
OutputPort() {
@@ -42,6 +51,8 @@ public final class OutputPort<T> extends AbstractPort<T> {
* to be sent; May not be <code>null</code>.
*
* @return <code>true</code> iff the <code>element</code> was sent; <code>false</code> otherwise.
+ *
+ * @since 1.1
*/
public boolean sendNonBlocking(final T element) {
return this.pipe.addNonBlocking(element);
diff --git a/src/main/java/teetime/stage/basic/distributor/Distributor.java b/src/main/java/teetime/stage/basic/distributor/Distributor.java
index ac5f845a..057a709e 100644
--- a/src/main/java/teetime/stage/basic/distributor/Distributor.java
+++ b/src/main/java/teetime/stage/basic/distributor/Distributor.java
@@ -31,7 +31,7 @@ public final class Distributor<T> extends AbstractConsumerStage<T> {
private IDistributorStrategy strategy;
public Distributor() {
- this(new RoundRobinStrategy());
+ this(new RoundRobinStrategy2());
}
public Distributor(final IDistributorStrategy strategy) {
diff --git a/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java b/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java
index e46807aa..e6cca92e 100644
--- a/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java
+++ b/src/main/java/teetime/stage/basic/distributor/RoundRobinStrategy2.java
@@ -18,9 +18,9 @@ package teetime.stage.basic.distributor;
import teetime.framework.OutputPort;
/**
- * @author Nils Christian Ehmke, Christian Wulf
+ * @author Christian Wulf
*
- * @since 1.0
+ * @since 1.1
*/
public final class RoundRobinStrategy2 implements IDistributorStrategy {
--
GitLab