Api mods

Modifications in the API to match the paper. Mainly Stream operation consume and produce. The examples also changed accordingly.
Remove this.  It's a bit sloppy to have TODO's in the examples.  If you want to track it, open an issue so we can milestone it and assign it to someone.