initial commit
add early stream implementation