implements TODO duplicate with error inside async Observables