Iniziato refactoring datastream project