Turbine StreamAggregator using ReactiveExtensions (RxJava)