add observable
Merge pull request #2 from virgo-agent-toolkit/songgao/observer

Add Obserable so that stream data can be duplicated