const { interval } = rxjs;
const { take } = rxjs.operators;


/* 
Az interval() egy Observable objektumot hoz létre,
ami másodpercenként egy új számot bocsájt ki 
*/
const numbers = interval(1000);

/* 
A take operátorral korlátozzuk, hogy csak az 
első 5 értéket kapjuk meg.
A teke() operátorokat a pipe() függvénnyel 
tudjuk használni.
*/
const fif = numbers.pipe(
    take(5)
)


/*
A subscribe() függvénnyel feliratkozunk az adatfolyamra.
A paraméterben leírjuk, hogy mit történjen az érkező értékkel.
*/
fif.subscribe({
    next: res => {
        console.log(res);
    }
})