Started implementation of new streaming example