草庐IT

android - 在 rxJava 中压缩超过 9 个 Observable

coder 2023-12-26 原文

遇到需要做10-12个小的并行查询并合并结果的情况。但是如果有一个 zip 方法可以让你组合最多 9 个 Observables，那么我不明白如何做更多。我尝试使用 zip 方法

public static <T, R> Observable<R> zip(Iterable<? extends ObservableSource<? extends T>> sources, Function<? super Object[], ? extends R> zipper)

但是却报错了

java.lang.ClassCastException: java.util.ArrayList cannot be cast to io.reactivex.ObservableSource

尝试看起来像这样

List<Observable> list = new ArrayList<>();
list.add(orderRepository.getOne(54, "id"));
list.add(orderRepository.getTwo(54, "id"));
list.add(orderRepository.getThree(54, "id"));
list.add(orderRepository.getFour(54, "id"));
list.add(orderRepository.getFive());
list.add(orderRepository.getSix(54, "id"));
list.add(orderRepository.getSeven(54, "id"));
list.add(orderRepository.getEight());
list.add(orderRepository.getNine());
list.add(orderRepository.getTen(54, "id"));
list.add(orderRepository.getEleven(54, "id"));
Observable.fromIterable(list);

return Observable.zip(list,
        new Function<Object[], OrderModel>() {
            @Override
            public OrderModel apply(Object[] objects) throws Exception {
                Logger.trace("objects = ", objects);
                return new OrderModel();
            }
        });

请举例说明如何在 Java 或 Kotlin 中执行此操作。

最佳答案 

    Observable one = Observable.zip(
        orderRepository.getOne(54, "id"), 
        orderRepository.getTwo(54, "id"),
        // Etc up to five (I think)
        Function zipper
    );

    Observable two = Observable.zip(
        one, orderRepository.getSix(54, "id"),
        orderRepository.getSeven(54, "id"),
        // Etc up to five,
        Function zipper
    );

冲洗并重复，直到您将所有可观察对象压缩在一起。

关于android - 在 rxJava 中压缩超过 9 个 Observable，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/51922827/

中压ObservableorderRepositorylistandroidkotlinrx-javareactivex

有关android - 在 rxJava 中压缩超过 9 个 Observable的更多相关文章

  1. 安卓apk修改(Android反编译apk) - 2

    最近因为项目需要，需要将Android手机系统自带的某个系统软件反编译并更改里面某个资源，并重新打包，签名生成新的自定义的apk，下面我来介绍一下我的实现过程。APK修改，分为以下几步：反编译解包,修改,重打包,修改签名等步骤。安卓apk修改准备工作1.系统配置好JavaJDK环境变量2.需要root权限的手机（针对系统自带apk,其他软件免root）3.Auto-Sign签名工具4.apktool工具安卓apk修改开始反编译本文拿Android系统里面的Settings.apk做demo,具体如何将apk获取出来在此就不过多介绍了，直接进入主题：按键win+R输入cmd，打开命令窗口，并将路

  2. ruby-on-rails - ActiveRecord::QueryCache#call 占用了超过 70% 的执行时间 - 2

    NewRelic向我展示了应用服务器中超过80%的执行时间发生在“MiddlewareActiveRecord::QueryCache#call”中这里是相关测试代码的要点(尽管我在其他API端点上看到了类似的结果)。Gist我正在AWSElasticBeanstalk上的t2.medium实例和t2.smallPostgresRDSDB上运行应用程序服务器，max_connections设置为100。我正在通过loader.io对此进行测试，对100个用户进行测试使用维护客户端负载设置(这意味着每分钟大约6000个请求)。有谁知道为什么QueryCache花费这么多时间？

  3. ruby-on-rails - 在 Rails 中压缩目录 - 2

    很难说出这里要问什么。这个问题模棱两可、含糊不清、不完整、过于宽泛或夸夸其谈，无法以目前的形式得到合理的回答。如需帮助澄清此问题以便重新打开，visitthehelpcenter.关闭10年前。我如何在ruby​​onrails中压缩一个目录？我试过ruby​​zip但没有成功。我不需要单独压缩目录的内容，只需压缩目录本身。

  4. ruby - 如果超过 5 秒，如何退出使用 Ruby 运行的进程？ - 2

    我正在用Ruby实现一个检查系统。它运行具有不同测试的可执行文件。如果解决方案不正确，则可能需要很长时间才能完成某些严格的测试。这就是为什么我想将执行时间限制为5秒。我正在使用system()函数来运行可执行文件:system("./solution");.NET有一个很棒的WaitForExit()方法，那么Ruby呢？有没有办法将外部进程的执行时间限制为5秒？谢谢 最佳答案 您可以使用标准超时库，如下所示:require'timeout'Timeout::timeout(5){system("./solution")}这样您就不

  5. ruby-on-rails - Rails、Minitest 和 Guard - 为什么 rb-fsevent 占用了超过 100% 的 CPU？ - 2

    我在我的Rails应用程序中运行守卫，测试套件(最小的)最近停止正常工作。如果幸运的话，它会运行所有测试一次，也许两次。在那之后，即使是一个小的测试文件被更改也需要很长时间才能响应，以至于使用gem变得徒劳无功。在测试运行时跟随top，我可以看到有一个ruby​​进程持续占用了超过100%的CPU。即使所有测试都已运行并且我没有对文件进行任何更改。ruby进程是:/Users/Bodacious/.rvm/gems/ruby-2.0.0-p247@MyApp/gems/rb-fsevent-0.9.3/bin/fsevent_watch--latency0.1/Users/Bodaio

  6. Android Studio开发之使用内容组件Content获取通讯信息讲解及实战（附源码 包括添加手机联系人和发短信） - 2

    运行有问题或需要源码请点赞关注收藏后评论区留言一、利用ContentResolver读写联系人在实际开发中，普通App很少会开放数据接口给其他应用访问。内容组件能够派上用场的情况往往是App想要访问系统应用的通讯数据，比如查看联系人，短信，通话记录等等，以及对这些通讯数据及逆行增删改查。首先要给AndroidMaifest.xml中添加响应的权限配置 下面是往手机通讯录添加联系人信息的例子效果如下分成三个步骤先查出联系人的基本信息，然后查询联系人号码，再查询联系人邮箱代码 ContactAddActivity类packagecom.example.chapter07;importandroid

  7. Android 10.0 设置默认launcher后安装另外launcher后默认Launcher失效的功能修复 - 2

    1.前言 在10.0的系统rom定制化开发中，在系统中有多个launcher的时候，会在开机进入launcher的时候弹窗launcher列表，让用户选择进入哪个launcher，这样显得特别的不方便所以产品开发中，要求用RoleManager的相关api来设置默认Launcher，但是在设置完默认Launcher以后，在安装一款Launcher的时候，默认Launcher就会失效，在系统设置的默认应用中Launcher选项就为空，点击home键的时候会弹出默认Launcher列表，让选择进入哪个默认Launcher.所以需要从安装Launcher的流程来分析相关的设置。来解决问题设置默认La

  8. ruby - 在 object.initialize 中，使用 self 是不是更好。超过 @？ - 2

    有一种约定，在可能的情况下，通过对象的实例变量来引用对象的属性。PracticalObject-OrientedDesigninRuby说:Alwayswrapinstancevariablesinaccessormethodsinsteadofdirectlyreferringtovariables...这显示了一个例子，我已经释义了:classGearattr_reader:chainring,:cog...defratio#thisisbad#@chainring/@cog.to_f#thisisgoodchainring/cog.to_fend我看到使用实例变量创建新对象的最常

  9. ruby - Cookie 数据大小超过 4K - 但其 'only' 1100 字节已加密 - 2

    我有一个使用Rack::Session::Cookie的Sinatra应用useRack::Session::Cookie,:key=>'my.key',:path=>'/',:expire_after=>3600,#Inseconds:secret=>'something'我在session中有一个地方可以设置数据，我转储了session，大约在erb调用之前有600字节puts"sessionis#{session.inspect}"==>400bytesoftext然后我得到Warning!Rack::Session::Cookiedatasizeexceeds4K.Warnin

  10. AiBote 2022 新研发的自动化框架，支持 Android 和 Windows 系统。速度非常快 - 2

    Ai-Bot基于流行的Node.js和JavaScript语言的一款新自动化框架，支持Windows和Android自动化。1、Windowsxpath元素定位算法支持支持Windows应用、.NET、WPF、Qt、Java和Electron客户端程序和ie、edgechrome浏览器2、Android支持原生APP和H5界面，元素定位速度是appium十倍，无线远程自动化操作多台安卓设备3、基于opencv图色算法，支持找图和多点找色，1080*2340全分辨率找图50MS以内4、内置免费OCR人工智能技术，无限制获取图片文字和找字功能。5、框架协议开源，除官方node.jsSDK外，用户可

随机推荐