[Streams] New Base - on/emit events.

Not yet tested properly !!!