Added functionality for streams

Fixes [MLHR-1384](https://malhar.atlassian.net/browse/MLHR-1384) and [MLHR-1385](https://malhar.atlassian.net/browse/MLHR-1385).

![image](https://cloud.githubusercontent.com/assets/1390651/4188874/0503177e-3777-11e4-9d56-e74b83367013.png)