import { throwError } from 'rxjs'; // ... method(): Observable<SomeClass> { // ... // from the if (failedCondition) { return throwError(''); } // ... }