Add Obserable so that stream data can be duplicated