使用bodyToFlux方法的webClient响应合并所有收到的响应,而不是将其分离出来

问题描述

  1. 我正在使用ParallelFlux运行许多任务。

  2. 但是当我使用bodyToFlux方法接收webClient响应时,它会合并所有输出响应,而不是一一得到。

  3. 我希望输出应该是一个一个而不是一个字符串,是否还有其他方法需要代替bodyToFLux使用。

    请求方法:

        Flux<String> responsePost = webClient.build()
                                //removed get,url and retrieve here                             
                                .bodyToFlux(String.class);
    
                    responsePost.subscribe(s -> {
                        //display response
                        });
    

    响应方法:

        public ParallelFlux<String> convertListToMap() {
                  //created list of string str
    
                return Flux.fromIterable(str)
                        .parallel(3)
                        .runOn(Schedulers.parallel())
                        .map( s -> {
                    //some logic here
                });
           }
    

    输出:

        parallel fulx reponse: springwebfluxparellelExample
    

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)