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 }