const { interval } = rxjs;

/* 5 másodpercenként egy szám kibocsájtása */
const numbers = interval(5000);

/* Feliratkozás az adatfolyamra */
numbers.subscribe({
    next: res => {
        console.log(res);
    }
})