Initial Demo
Refactoring ...
Observable<Observable<T>> for each instance
Added Eureka integration to HystrixStreamingAggregator
Removed commented code. Added preliminary error handling
... in dev ...