main.ts

main.ts

import {Observable} from "rxjs";

//Creating new Datasource using that API.
let nums = [0,1,2,3,4,5,6,7,8,9];

//createing Observable
let dataSource = Observable.create(ob=>{

    //loop through the nums
    for(let n in nums){
        ob.next(n);
    }
    ob.complete();
});

//Simplest way of building an observer, where in passing all three functions directly.
dataSource.subscribe(
    value => console.log(`Incoming Value:- ${value}`),
    e =>  console.log(`Error Happend:- $(e)`),
    ()=> console.log("We are done!!!")
);