project-reactor

    8热度

    2回答

    反应流 - 批处理超时

    我正在寻找替换一个自制的日志处理库，看起来非常接近ReactiveStreams与io.projectreactor。我们的目标是减少我们维护的代码，并利用社区添加的任何新功能（关注操作员融合）。 作为开始，我需要使用stdio并将多行日志条目合并到流水线​​下方的文本blob中。该用例在Filebeat文档的multiline log entries一章中详细解释（除了我们希望它在进程中）。 到
    rx-java reactive-programming project-reactor reactive-streams 2017-07-12

    0热度

    1回答

    Reactor/RxJava SQS

    我是新来的整个反应范式，我试图了解如何从像SQS队列读取时背压是如何工作的。 反应堆你有你的流量和RxJava你有你的可观察投票SQS像背景： while (true) { Future<ReceiveMessageResult> future = sqsClient.receiveMessageAsync(queueUrl); //emit or send to subscr
    rx-java project-reactor 2017-07-14

    0热度

    1回答

    Spring 5 Web反应 - Web客户端 - 在响应流上使用flatmap（）

    我想了解为什么在response流上使用flatmap（），例如this后，例如（直接从引用粘贴的副本） final ClientRequest request = ClientRequest.GET(url) .accept(MediaType.TEXT_EVENT_STREAM).build(); Flux<Alert> alerts = webClient.exchange(r
    spring reactive-programming project-reactor spring-webflux 2017-07-25

    0热度

    1回答

    春季数据MongoDB save（）结果双重插入

    我们遇到了以下行为，但我们希望知道它是否是预期的，以及是否有兴趣将它记录为一些有种陷阱。 我们与春天启动2 /春WebFlux试验和设置了一个小的应用程序，主要有这样的事情（所有缩短）： @PostMapping public Mono<Todo> addTodos(@RequestBody Person person) { return personService.addPerson
    spring spring-mvc spring-data-mongodb reactive project-reactor 2017-07-25

    1热度

    1回答

    Spring Boot v2.0.0.M2 webflux和执行器

    我无法获得Actuator与Spring Boot v2.0.0.M2和Netty一起工作。以下依赖性在build.gradle使用： compile "org.springframework.boot:spring-boot-starter-actuator" compile "org.springframework.boot:spring-boot-starter-data-redi
    spring-boot netty spring-boot-actuator project-reactor spring-webflux 2017-07-25

    5热度

    1回答

    Spring Reactive WebClient

    我有一个被动rest api（webflux），也使用spring WebClient类来请求来自其他休息服务的数据。 简化设计： @PostMapping(value = "/document") public Mono<Document> save(@RequestBody Mono<Document> document){ //1st Problem: I do not know ho
    java project-reactor reactive 2017-06-22

    0热度

    1回答

    有人可以解释Reactor Mono流中的.then（）方法的注意事项吗？

    我有两个测试函数，我期望返回相同的结果。第一个（monoTest3）在'.then（）'方法中使用lambda表达式。第二个不是。 为什么我会得到结果？ 使用ReactiveX和lambda表达式时，有什么做什么和不该做什么？ 在代码下面进一步monoTest3产生 monoVoid called Success ---- monoVoid2 called Success 和monoT
    spring lambda java-8 reactive-programming project-reactor 2017-06-22

    0热度

    2回答

    如何对StepVerifier中的所有其余元素执行断言？

    StepVerifier有一个assertNext方法，该方法允许对下一个元素的值执行断言。 StepVerifier.create(dataFlux) .assertNext(v -> checkValue(v) .verifyComplete(); 什么是对每个剩余元素执行断言的好方法（例如检查每个元素是否为正数）？我期望像assertEveryNextElem
    java unit-testing project-reactor 2017-06-26

    0热度

    1回答

    第二磁通也从来没有开始做其工作

    我想测试春天反应器，并为我实现了一个小例子，这里是有关的代码： 应用： @SpringBootApplication public class Application implements CommandLineRunner { @Autowired private ServiceData data; public static void main(String[
    spring project-reactor 2017-06-27

    0热度

    1回答

    rxjava反应器，工具传播例外

    我试图写一个自动的reactiv方式传播检查的异常，而无需编写锅炉板代码与我的运营商内部的静态块的工具： public class ReactRethrow { public static <T, R> Function<T, R> rethrow(Function<T, R> catchedFunc) { return t -> { try {
    exception rx-java project-reactor propagation 2017-06-29
最新问题