Moved parser to use RxJava for better composability in working with the
event streams emitted.