Observable (reactive streams) pattern implemented using es2015 in Typescript - View it on GitHub