Add draft architechture for async streaming environment

Add draft architechture for async streaming environment #123