Making Map and Reduce consumers generic, to allow working with bare Reactor.