Implementing simple observer for observable - Coding Blast - www.codingblast.com

simple-observer.ts

import { Observable, Observer } from 'rxjs';

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

let source = Observable.from(words);

class SimpleObserver implements Observer<string> {
    next(value: string) {
        console.log('next: ', value);
    }

    error(err: any) {
        console.log('error: ', err);
    }

    complete() {
        console.log('complete');
    }
}

let observer = new SimpleObserver();

source.subscribe(observer);