如何解决使用bodyToFlux方法的webClient响应合并所有收到的响应,而不是将其分离出来
-
我正在使用ParallelFlux运行许多任务。
-
但是当我使用bodyToFlux方法接收webClient响应时,它会合并所有输出响应,而不是一一得到。
-
我希望输出应该是一个一个而不是一个字符串,是否还有其他方法需要代替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
解决方法
-
在这里创建而不是返回ParallelFlux 要返回变量的ResponseBody类,将您的响应分配给 变量,并将其返回给API函数的调用者。
public ParallelFlux<ResponseBody> convertListToMap() { //created list of string str return Flux.fromIterable(str) .parallel(3) .runOn(Schedulers.parallel()) .map( s -> { //some logic here }); } Flux<String> responsePost = webClient.build() //removed get,url and retrieve here .bodyToFlux(ResponseBody.class);
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。