import {Observable} from 'rxjs';

let words = ['coding blast', 'badword', 'coding', 'blast'];

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

        observer.next(word);
    }

    observer.complete();
});


let subscriber = {
    next(value) {
        console.log('Subscriber - next: ', value);
    },
    error(err) {
        console.log('Subscriber - error: ', err);
    },
    complete() {
        console.log('Subscriber - complete');
    }
};

console.log('before subscribe');

source.subscribe(subscriber);

console.log('after subscribe');