Add initial EventStream interface
Migrate event streaming to node streams API