) Flux.merge([_ <: I]*)reactor.core.scala.publisher.Flux[I] <and>
[I](sources: org.reactivestreams.Publisher[_ <: I]*
浏览 10提问于2019-01-07得票数 0
回答已采纳
2回答
我目前的理解非常模糊，我倾向于认为map是同步的，而flatMap是异步的，但我真的无法绕过它。destFile .flatMap(it::transferTo)我有一些文件(一个Flux
浏览 1提问于2018-03-06得票数 45
回答已采纳
我得到了一个Publisher<DataBuffer> inputStream作为论据。我想将该流转换为字符串，记录该字符串，然后我必须像Publisher一样将该字符串再次传递给另一个方法。示例： return DataBufferUtils.join(inputStream<Object> delegate(Pu
浏览 0提问于2019-07-16得票数 2
回答已采纳
我需要在反应式管道中将外部库返回的CompletionStage转换为单声道。如何处理从调用返回的异常(我想忽略它们并继续执行序列)？10000); e.printStackTrace();}
.toFuture();
} 堆栈跟踪 2021-10-11T02:16:09,944 main r.c.p.Operators
浏览 169提问于2021-10-10得票数 1
回答已采纳
谁能举个例子说明Flux.buffer(Publisher other)是如何工作的，我无法利用其他publisher将原始流量分割成多个列表。例如： strings.add("A"); Flux<String> stringFlux = <em
浏览 1提问于2017-05-05得票数 0
我不明白thenEmpty、thenMany和flatMapMany在Flux上的用法和区别，或者spring webflux中的Mono。
浏览 0提问于2018-01-15得票数 25
回答已采纳
1回答
我试图在Java8中使用泛型类型的Flux泛型转换器，我的代码是基于这个的。它的基本思想是实现这个特定的转换器String -> Integer。.log(); }
到类型化转换器String ->到我想要的任何类型。Flux<OUT> createFluxConverter(String[] data)。impo
浏览 1提问于2021-03-11得票数 0
回答已采纳
3回答
看来他无法反序列化数据。你能告诉我假冒伪劣是否与Flux和Monno兼容吗？谢谢
{“时间戳”："2019-05-29T07:39:43.998+0000"，“路径”：“/业余爱好/”，“状态”：500，“错误”：“内部服务器错误”，“消息”：“类型定义错误:简单类型，类reactor.core.publisher.Flux；嵌套异常是com.fasterxml.jackson.databind.exc.InvalidDefini
浏览 1提问于2019-05-29得票数 0
回答已采纳
接受iterable的压缩包将我的对象转换为Object[] vs merge。压缩后，我无法执行其他转换，因为我丢失了对象类型。这是与流的reduce组合器相同的概念吗？只是想知道如何正确使用它。final List<Object[]> list = Flux .coll
浏览 2提问于2019-08-15得票数 1
","five","six");
.concat(Flux.fromIterable(l1),Flux.fromIterable(l2))我创建了以下测试用例：@GetMapping("/test4") List<String> indecies = Arra
浏览 2提问于2017-06-23得票数 1
回答已采纳
这两个示例方法的现有代码如下所示： Stringextends CatalogInfo> T get(String attName, String attValue, Class<T> clazz) {
Strin
浏览 4提问于2017-07-28得票数 3
回答已采纳
假设我们需要根据一个Flux资源的内容创建一个Closeable。为了清晰起见，需要将BufferedReader转换为Flux<String>。BufferedReader reader = createReader("my_resource_path");
Flux<String> flux = Flux.fromIterable(() ->我正在寻找一种关闭BufferedReader的方法，如果
浏览 1提问于2020-06-09得票数 2
回答已采纳
3回答
但是我无法运行应用程序，因为我得到了以下错误
import com.thomsoncodes.todo.repository.ToDoRespository;
import reactor.core.pu
浏览 0提问于2019-02-20得票数 0
回答已采纳
在Spring5.0.0.RC4参考文档中，它说：
at reactor.core.<em
浏览 7提问于2017-10-06得票数 9
回答已采纳
2回答
new ServicePollerImpl(); params.put("id", forId);
Flux<ServerEvent> serverEventFlux在从原始流量返回控制器之前，
浏览 1提问于2018-06-22得票数 1
回答已采纳
我想出了以下解决方案，它每10秒发出一次心跳元素，而不管是否已经发出真正的元素：ConnectableFlux<String> sharedOriginalFlux<String> addHeartbeat(Flux<S
浏览 4提问于2019-10-30得票数 6
回答已采纳
我刚开始学春季启动，我无法从我的春季启动书中得到一个例子来工作。这是代码
Thomas.ChapterController中构造函数的参数0需要一个could >类型'Thomas.ChapterRepository‘的bean，而这个bean是找不到的。操作：import org.springframework.context.
浏览 0提问于2019-03-06得票数 2
>,我的应用程序无法启动它，因为： import org.springframework.stereotype.Repository;
import reactor.core.publi
浏览 0提问于2017-09-02得票数 2
3回答
寻找将流量转换为List<Object>的方法。如果我使用block()，就会出错。所以，需要在不阻塞呼叫的情况下进行协商。Flux.from(Collection.find())public List<Test> findAll() {
return Flux.from(testCollection.find()).collectListblocking, wh
浏览 2提问于2020-05-31得票数 4
2回答
这是样板代码:我想做这样的事情- method1(email).map(result -> {Mono<Object1> return method2(email); //method2 returns Flux<Object2>
浏览 0提问于2018-08-30得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
