Как получить последнее событие в rxjs?

Question

[Сергей]

При помощи чего в rxjs можно реализовать получение последнего события, если подписка на него произошла только через некоторый промежуток времени.
Пример:
1. Происходит клик мышки
2. уведомляются все кто был подписан на это событие
3. проходит время
4. кто о еще подписывается и в этот момент он получает последнее событие.
Возможно в rxjs нет такой возможности, тогда как можно такое реализовтаь?

Answer 1

[Сергей]

Нашел решение:

let count = 0

        let obs = Observable.create(s=>{
            setInterval(()=>{
                s.next(count++)
                // s.complete()
            },2000)
        }).publishReplay()

        obs.connect()//Без этого не работает

        obs.subscribe(
            v=>console.log(`A: ${v}`)
        )

        setTimeout(()=>{
            obs.subscribe(
                v=>console.log(`B: ${v}`)
            )
        },10000)

Answer 2

[Александр Манаков]

Используйте BehaviorSubject

Answer 3

[_ _]

publishReplay().refCount()
connect() будет не нужен