data_source

DataSource provides an infinite stream of data and DataStage provides a GenStage-producer you can subscribe to in order to fetch data/events from the given source.