Obtenha o valor mais recente de um Observável e emita-o imediatamente
Estou tentando obter o valor mais recente de um determinadoObservable
e faça com que ele seja emitido imediatamente quando for chamado. Dado o código abaixo como um exemplo:
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
Isso não funciona porque, ao fazer isso, oflatMap
vai emitirmyObservable1
que por sua vez terá que emitir para alcançar omap
. Não sei se é possível fazer isso. Alguém tem alguma pista de como alcançar esse objetivo? Obrigado