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

added javadoc

parent 84357fb0
No related branches found
No related tags found
No related merge requests found
...@@ -18,6 +18,15 @@ package teetime.framework; ...@@ -18,6 +18,15 @@ package teetime.framework;
import teetime.framework.signal.ISignal; import teetime.framework.signal.ISignal;
import teetime.framework.signal.TerminatingSignal; 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> { public final class OutputPort<T> extends AbstractPort<T> {
OutputPort() { OutputPort() {
...@@ -42,6 +51,8 @@ public final class OutputPort<T> extends AbstractPort<T> { ...@@ -42,6 +51,8 @@ public final class OutputPort<T> extends AbstractPort<T> {
* to be sent; May not be <code>null</code>. * to be sent; May not be <code>null</code>.
* *
* @return <code>true</code> iff the <code>element</code> was sent; <code>false</code> otherwise. * @return <code>true</code> iff the <code>element</code> was sent; <code>false</code> otherwise.
*
* @since 1.1
*/ */
public boolean sendNonBlocking(final T element) { public boolean sendNonBlocking(final T element) {
return this.pipe.addNonBlocking(element); return this.pipe.addNonBlocking(element);
......
...@@ -31,7 +31,7 @@ public final class Distributor<T> extends AbstractConsumerStage<T> { ...@@ -31,7 +31,7 @@ public final class Distributor<T> extends AbstractConsumerStage<T> {
private IDistributorStrategy strategy; private IDistributorStrategy strategy;
public Distributor() { public Distributor() {
this(new RoundRobinStrategy()); this(new RoundRobinStrategy2());
} }
public Distributor(final IDistributorStrategy strategy) { public Distributor(final IDistributorStrategy strategy) {
......
...@@ -18,9 +18,9 @@ package teetime.stage.basic.distributor; ...@@ -18,9 +18,9 @@ package teetime.stage.basic.distributor;
import teetime.framework.OutputPort; 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 { public final class RoundRobinStrategy2 implements IDistributorStrategy {
......
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