无法在rxjava2中解析方法'subscribe(匿名io.reactivex.functionx.Consumer <java.util.List <... >>)'?

Qin*_*Qin 5 rx-java2

在toList运算符执行之后,原始的Flowable <<\List >>转换为Single <<\List >>.事实证明,如果我创建Consumer来订阅Single,那么除了Object之外,不能更改Consumer值类型?

 @Override
public void loadBannerData(final ADFilterType adFilterType) {
    remoteListDataSource.getBannerListData(adFilterType)
            .flatMap(new Function<List<BannerBeanList.BannerBean>, Publisher<?>>() {
                @Override
                public Publisher<?> apply(List<BannerBeanList.BannerBean> bannerBeen) throws Exception {
                    return Flowable.fromIterable(bannerBeen);
                }
            })
            .toList()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
           /******************************Consume Value Type**************************
            .subscribe(new Consumer<List<BannerBeanList.BannerBean>>() {
                @Override
                public void accept(List<BannerBeanList.BannerBean> bannerBeens) throws Exception {
                    mainTabView.showMainBanner(bannerBeens);
                }
            });
          *****************************************************************************/
}
Run Code Online (Sandbox Code Playgroud)

aka*_*okd 6

从我的评论:这发生是因为你有Publisher<?>代替Publisher<BannerBeanList.BannerBean>你的代码.IDE通常无法推断出lambda或功能接口的类型,你最终会得到什么?或者在使用某些生成/转换重构函数时将Object作为其类型.