RxJava-如何使用Flowable所引用类型的方法？

Question

我有两个Flowable，我通过压缩和过滤来进行操作，如下所示：

Flowable<Position> position1 = obj1.getPosition(); // position in 3D enviroment
Flowable<Position> position2 = obj2.getPosition();

position1.zipWith(position2, (pos1, pos2) ->
    getDistance(pos1,pos2) //method returning distance between positions
).filter(distance->distance<=5).subscribe();

现在，当像这样发出已过滤的项目时，我想使用类Position中的方法：

position1.zipWith(position2, (pos1, pos2) ->
    getDistance(pos1,pos2) //method returning distance between positions
).filter(distance->distance<=5).subscribe(pos1.getX()-pos2.getX());

该怎么做？

Answer 1

解决这个问题的最简单方法是创建像这样的包装器类