Получите последнее значение Обсерватории и немедленно испустите его
Я пытаюсь получить последнее значение данногоObservable
и заставить его испускать немедленно, как только он будет вызван. Приведенный ниже код в качестве примера:
return Observable.just(myObservable.last())
.flatMap(myObservable1 -> {
return myObservable1;
})
.map(o -> o.x) // Here I want to end up with a T object instead of Observable<T> object
Это не работает, потому что, делая этоflatMap
будет излучатьmyObservable1
который в свою очередь должен будет излучать, чтобы достичьmap
, Я не знаю, возможно ли сделать такое. Кто-нибудь знает, как достичь этой цели? Спасибо