Asynchronous Programming and Real-time Stream Processing with Reactive Extensions (Rx)