Use map stream directly instead of es.map.

Refactored this as the plugin doesn't need all of event stream.