-
9 votesanswersviews
在akka-stream中如何从期货集合中创建无序的来源
我需要从 Future[T] 的集合中创建 akka.stream.scaladsl.Source[T, Unit] . 例如,有一组期货返回整数, val f1: Future[Int] = ??? val f2: Future[Int] = ??? val fN: Future[Int] = ??? val futures = List(f1, f2, fN) 如何创建一个 val sou... -
1 votesanswersviews
为什么Reactor 3需要单声道类型?
Reactor 3有2种主要数据类型,它们都是反应流发布者 reactor.core.publisher.Mono<T> reactor.core.publisher.Flux<T> 我理解Mono是0或1个元素的流,而Flux是0或N个元素的流 . 由于Mono和Flush都在实施 org.reactivestreams.Publisher<T> ... -
2 votesanswersviews
针对Reactor(或Akka)解决方案的CompletableFuture解决方案
我有以下方法使用 CompletableFuture 这样: public AClass aMethod() { CompletableFuture<SomeClassA> someClassAFuture = CompletableFuture.supplyAsync(() -> someMethodThatReturnsA()); Compl... -
2 votesanswersviews
在 Spring 季启动webflux的微服务,谁是订户?
注意:这里的术语订阅者和订阅正在从反应流规范中使用 . 在spring boot webflux的微服务中考虑以下@RestController方法 . @GetMapping(path = "/users", produces = MediaType.APPLICATION_JSON_VALUE) public Flux<TradingUser> list... -
5 votesanswersviews
Spring Boot Webflux / Netty - 检测关闭连接
我一直在使用webflux启动器( spring-boot-starter-webflux )使用spring-boot 2.0.0.RC1 . 我创建了一个简单的控制器,返回无限的通量 . 我希望发布者只有在有客户端(订阅者)时才能正常工作 . 假设我有一个像这样的控制器: @RestController public class Demo { @GetMapping(value ...