import { Observable, from } from "rxjs";
const arr = [1,2,3]
var observable = from(arr)
arr.push(22)
setTimeout(() => {
var subscription = observable.subscribe(
(x:any) => console.log(x)
)
},2000);
arr.push(333)
setTimeout(() => arr.push(4444), 5000)