replaced Rx framework with Akka

I could not implement properly some features with Rx Observables
and it was introducing more complexity than simplicity. The unit tests
were unreliable at times and I do not master the framework well enough.

For instance I never knew if obs.tumbling() could use a subset of 
events from obs reliably, and when the subscription were using
new threads.