我希望获取给定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
,而myObservable1
必须要发出才能到达map
。我不知道是否有可能做到这一点。有没有人知道如何实现这个目标?谢谢。
myObservable
是一个热可观察对象,它会在不规则的时间间隔内发出例如 "1"、"2"、"3" 等值。我想要做的是,在到达return
指令时能够获取myObservable
的最新值(在本例中为 "3")。 - E-KamistartsWith
是默认值,而replay(1)
+connect
不起作用吗? - Vincent D.