Trying to implement a logstash like tool based on reactive streams