Use Observable.reduce in batch example