运行使用 RxJava 编码时出现编译错误

Question

我是 RxJava 的新手所以请原谅我所有的新手错误 ;)

我有以下代码：

Observable
            .fromIterable( observables )
            .flatMap(task -> task.observeOn(Schedulers.computation()))
            // wait for all tasks to finish
            .lastOrError()
            .flattenAsObservable( x -> someWeirdMapWithObject.values())
            .cast(BrandBuilder.class)
            .map( brandBuilder -> brandBuilder.build() )

observables 是将数据写入 someWeirdMapWithObject 的 Observable 列表。顾名思义，someWeirdMapWithObject 具有 Object 作为值。

奇怪的是，在 Intellij IDEA 中，这段代码可以正常运行，没有错误，没有警告（除了一个 - brandBuilder.build() 可以内联）。但是当我尝试编译这段代码时，出现编译错误：

error: cannot find symbol
                .map( brandBuilder -> brandBuilder.build() )
                                                  ^
  symbol:   method build()
  location: variable brandBuilder of type Object

当我将最后一行更改为：

.map( brandBuilder -> ((BrandBuilder) brandBuilder).build() )

一切都很好。

我的问题是：

为什么转换运算符不起作用？
我的代码正确吗？有没有更好的执行方式？
以及为什么（引用 Tommy Wiseau 的话：'Why, Java why?'）此代码无法编译？

提前感谢您的回复；）

编辑

下面更好的例子（作为 Junit 测试，我注意到当我制作相同类型的可观察对象时，这段代码将编译，否则它不会）：

@Test
public void test() throws Exception {
    Observable<String> first = Observable.fromCallable(() -> "HEY").delay(250, TimeUnit.MILLISECONDS);
    Observable<Integer> second = Observable.fromCallable(() -> 1).delay(350, TimeUnit.MILLISECONDS);
    List<Observable> observables = com.google.common.collect.Lists.newArrayList(first, second);
    Map<Long, Object> someWeirdMapWithObject = com.google.common.collect.ImmutableMap.of(
            1L, new BrandBuilder(1),
            2L, new BrandBuilder(2)
    );
    Observable
            .fromIterable(observables)
            .flatMap(task -> task.observeOn(Schedulers.computation()))
            // wait for all tasks to finish
            .lastOrError()
            .flattenAsObservable(x -> someWeirdMapWithObject.values())
            .cast(BrandBuilder.class)
            .map(BrandBuilder::build)
            .toList().blockingGet();
}

class BrandBuilder{
    private int bar;
    BrandBuilder(int bar) {
        this.bar = bar;
    }
    public Brand build(){
        return new Brand(this.bar);
    }
}

class Brand{
    private int bar;
    Brand(int bar) {
        this.bar = bar;
    }
}

Answer 1

问题似乎来自此声明中的原始类型：

List<Observable> observables =
    com.google.common.collect.Lists.newArrayList(first, second);

这似乎会在下面的流程中抛出 javac 并阻止 generics/inference 正常工作。使用

List<Observable<?>> observables =
   com.google.common.collect.Lists.newArrayList(first, second);

相反，下面的所有内容都应该编译。

对我来说，最新的 Eclipse 确实指出了编辑器中的问题，突出显示了 ::build 部分，所以我猜 IntelliJ 没有报告错误可能是那里的错误。

运行使用 RxJava 编码时出现编译错误

Compilation error while running code with RxJava

java

rx-java

rx-java2

运行 使用 RxJava 编码时出现编译错误

Compilation error while running code with RxJava

java

rx-java

rx-java2

运行使用 RxJava 编码时出现编译错误