Cacher is the code snippet organizer for pro developers

import {Observable} from "rxjs/Observable";
import "rxjs/add/operator/map"; //this import statement has side effect of adding map to observable
import "rxjs/add/operator/filter";

let numbers = [1,5,10];
let source = Observable.create(observer=>
    {
        let index = 0;
        let produceValue = ()=>{
            observer.next(numbers[index++]);
            if (index<numbers.length){
                setTimeout(produceValue,250);
            }
            else{
                observer.complete();
            }
        }
        produceValue();
    }
).map(n=>n*2)
    .filter(n=>n>4);

source.subscribe(
    value=>console.log(`value:${value}`),
    e=>console.log(`error: ${e}`),
    ()=>console.log("complete")
);