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

        observer.next(word);
    }

    observer.complete();
});