Parsing logs through a Reactive scheduler