RxJava2将两个Flowable压缩成一个

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了RxJava2将两个Flowable压缩成一个，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1230字，纯文字阅读大概需要2分钟。

内容图文

我正在努力寻找任何将两个Flowable压缩成一个的RxJava2示例.

我试图修改this test以包含一些东西

    Integer[] ints = new Integer[count];
    Integer[] moreints = new Integer[count];
    Arrays.fill(ints, 777);
    Arrays.fill(moreints, 777);

    Flowable<Integer> source = Flowable.fromArray(ints);
    Flowable<Integer> anothersource = Flowable.fromArray(moreints);

    Flowable<Integer> zippedsources = Flowable.zip(source, anothersource,
            new BiFunction<Flowable<Integer>, Flowable<Integer>, Flowable<Integer>>() {

                @Override
                public void apply(Flowable<Integer> arg0, Flowable<Integer> arg1) throws Exception {
                    return arg0.blockingFirst() + arg1.blockingLast();
                }

    }).runOn(Schedulers.computation()).map(this).sequential();

编辑：我正在尝试从源和anothersource获取一个Integer并将它们添加起来,但它似乎与RxJava1的方式完全不同…我尝试了一系列变体返回Integer,Publisher,Flowable和void但仍然继续在zip运算符本身上的Eclipse和错误.

我无法弄清楚.zip中的内容(Iterable<？extends Publisher<？extends T>&gt ;, Function<？super Object [],？extends R>).

解决方法:

由于您只需要压缩两个flowable,您可以使用Flowable.zipWith Operator.

它的使用方式如下：

source.zipWith(anotherSource, new BiFunction<Integer, Integer, Integer>() {
    @Override public Integer apply(Integer a, Integer b) {
        return a + b;
    } 
};

内容总结

以上是互联网集市为您收集整理的RxJava2将两个Flowable压缩成一个全部内容，希望文章能够帮你解决RxJava2将两个Flowable压缩成一个所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端