Observable

by azhwani

JavaScript

let sourceofobj = Rx.Observable.of({"name":"A","age":20});
sourceofobj.subscribe(val => console.log(val.name));

let sourceof = Rx.Observable.of([1,2,3]);
sourceof.subscribe(val => console.log(val));

let sourcefrom = Rx.Observable.from([1,2,3]);
sourcefrom.subscribe(val => console.log(val));

let sourceevent = Rx.Observable.fromEvent(document,'click');
sourceevent.subscribe(event => console.log("CLICK IN: "+event.timeStamp));

let sourcecrt = new Rx.Observable.create((obs) => {
    obs.next("Hello world0;");
});
sourcecrt.subscribe(val => console.log(val));

let sourceobs = new Rx.Observable((obs) => {
    obs.next("Hello world1;");
});
sourceobs.subscribe(val => console.log(val));