Fix test + add Observable.flatScan