Async observable with setTimeout
import {Observable} from "rxjs";
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,2000);
}
else{
observer.complete();
}
}
produceValue();
}
);
source.subscribe(
value=>console.log(`value:${value}`),
e=>console.log(`error: ${e}`),
()=>console.log("complete")
);