Pulse7
8/19/2017 - 10:07 AM

Observer | Observer with interface

Observer | Observer with interface

import {Observable,Observer} from "rxjs";
let numbers = [1,5,10];
let source = Observable.from(numbers);

class MyObserver implements Observer<number>{
    next(value){
        console.log(`value:${value}`);
    }

    error(e){
        console.log(`error: ${e}`);
    }

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

source.subscribe(new MyObserver());
source.subscribe(new MyObserver());