001    package biz.hammurapi.dataflow;
002    
003    
004    public class ChainingMixer extends AbstractMixer {
005    
006            private String name;
007            private JoinPredicate predicate;
008    
009            public ChainingMixer(String name, JoinPredicate predicate) {
010                    this.name = name;
011                    this.predicate = predicate;
012            }
013    
014            protected void join(InputEntry[] inputs, String activatorName, DataSink sink) {
015                    if (predicate.toBeJoined(inputs, activatorName)) {
016                            sink.addData(chainInputs(inputs));
017                    }
018            }
019    
020            public String getName() {
021                    return name;
022            }
023    
024    }