const simpleObservable = new Observable( (observer) => { observer.next("My message");...

У меня есть ReplaySubject, который накапливает данные с оператором scan, и каждые 10000 мс...