a set of helper function design to mange stream - View it on GitHub