Creating Observable error with throw - error method on observer - Coding Blast - www.codingblast.com

creating-observable-error.ts

let source = Observable.create(observer => {
    for (let word of words) {
        if (word === 'badword') {
            throw new Error('Bad word!');
        }

        observer.next(word);
    }

    observer.complete();
});