reactive-programming

当使用monix。eval。Task或zio。 task时。有一个简单的方法来转换任务的选项任务的选项？ ###如果你想要一个纯ZIO溶液，你可以使用.foreach with identity:与identity:： val fx: Option[UIO[Int]] = Option(Tas...

我使用的是Java WebFlux 2。5。2版本。我需要提取纯文本，这是作为POST请求，然后我将不得不处理文本。如何从ServerRequest对象中提取主体？ 我粘贴我的路由器和处理程序代码。附加图像与观察窗口，其中显示错误...

我已经使用Flux。using()查询了一些外部资源。现在我想实现一种乐观锁定:在查询开始执行之前读取一些状态，并在查询完成后检查它是否被更新。如果是这样-抛出一些异常来中断http请求处理。 我已经通过使用doOnCo...

我是新的Webflux和试图建立一个应用使用spring Webflux。我暴露了一个http post结束点，它接受json并立即返回202，并开始在后台处理请求。 这不是工作的预期，我得到立即202，但Mono处理没有发生 @Configura...

我有一个闪亮的应用程序，我想做一个标题说“Q1”，当用户选择1月1日和Q2，如果用户选择4月1等，但由于某些原因，我不能转换日期范围输入字符。 例如，我知道这段代码在普通字符串上工作: date <- "202...

我们把代码从RestTemplate移到WebClient来实现非阻塞调用，我们差不多完成了。但在将代码转移到WebClient后，我们面临的问题是，当客户端调用我们的API时，我们的响应是空白的。尽管我们的后端客户端有响应。 我...

我想用不阻塞的netty服务器和使用key斗篷的身份验证来运行基于web流量的web应用程序。 似乎键盘斗篷不支持netty服务器。是否有一种方法可以覆盖键盘斗篷的默认行为，并使用netty而不是tomcat ？ 这是需要的，因...

基于一个条件，是否有可能完成一个完整的未来？换句话说，将成功转化为一个异常的结果？有API吗？ 此刻我在做下面的事情，但感觉很尴尬，很复杂: CompletableFuture<CustomClass> inputFuture = doWork();...

我正试着把安培- android的部分部件送到c#。这个图书馆大量使用无功流。不幸的是，我不习惯用它来工作。我认为我理解了基本概念，但一些方法在c#中并不存在(我使用的是unk ve4 。 net)，我不知道如何重写代码以得...

我在R上写了一个小标准应用程序，它运行得很好。 它扫描*。png文件在一个文件夹中，提取一些统计数字的像素粒度和颜色。 现在我的想法是把它转到闪亮的地方。虽然我曾经写过一些更小的广告应用程序，但我从来没...

我有这样的课 public class Person { private String name; private String age; private Boolean student; ... // getters and setters } public class PersonDt...

在我的应用程序中，我有一些类似的东西: this._personService.getName(id) .concat(this._documentService.getDocument()) .subscribe((response) => { console.log(respons...

在我的弹簧引导应用程序中，我有一个类似的方法。 public Flux<Data> search(SearchRequest request) { Flux<Data> result = searchService.search(request);//this returns Flux<Data> ...

我有一个可流动的接收文件系统事件(e)。g:在文件文件编辑器完成后，文件更新使用ino的文件，然后将这些事件移交给处理。 在不同线程中发生的这个下游处理可能会更新更新的文件。这就创建了新的文件系统事件。 fi...

我有一个类似的出版商: enum RemoteError: Error { case networkError(Error) case parseError(Error) case emptyResponse } func getPublisher(url: URL) -> AnyPublisher<Entiy, Remote...