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

added javadoc, explaning the behavior on multiple signals

parent 32bfb436
No related branches found
No related tags found
No related merge requests found
...@@ -54,6 +54,17 @@ public class Merger<T> extends AbstractStage { ...@@ -54,6 +54,17 @@ public class Merger<T> extends AbstractStage {
this.send(this.outputPort, token); this.send(this.outputPort, token);
} }
/**
* This method is executed, if a signal is sent to a instance of this class.
* Multiple signals of one certain type are ignored, if they are sent to same port.
* Hence a signal is only passed on, when it arrived on all input ports, regardless how often.
*
* @param signal
* Signal which is sent
*
* @param inputPort
* The port which the signal was sent to
*/
@Override @Override
public void onSignal(final ISignal signal, final InputPort<?> inputPort) { public void onSignal(final ISignal signal, final InputPort<?> inputPort) {
this.logger.trace("Got signal: " + signal + " from input port: " + inputPort); this.logger.trace("Got signal: " + signal + " from input port: " + inputPort);
......
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