001    package biz.hammurapi.dataflow;
002    
003    /**
004     * Source of data.
005     * @author Pavel
006     */
007    public interface DataSource {
008            
009            String getName();
010            
011            /**
012             * Adds data sink to the source. Data source multiplexes data it 
013             * produces to all sinks unless one of sinks returns true from addData(),
014             * which terminates multiplexing.
015             * @param sink
016             */
017            void setSink(DataSink sink);
018    
019    }