首页 > Java > 创建能够在未来发布任意事件的 Flux

创建能够在未来发布任意事件的 Flux

PHPz
发布: 2024-02-09 11:50:24
转载
505 人浏览过

php小编苹果将为大家介绍一个令人兴奋的开发工具——Flux。Flux 是一个用于构建用户界面的应用程序架构,它专注于单向数据流的概念,使得状态管理变得简单而可预测。通过创建 Flux 架构,开发人员可以轻松管理应用程序的状态,并能够在未来发布任意事件,实现更灵活的应用程序开发。Flux 的简洁性和可扩展性使得它成为现代前端开发的理想选择。接下来,我们将深入探讨 Flux 的工作原理和如何使用它来构建出色的用户界面。

问题内容

我想创建一个自定义 flux ,能够在将来发布任意事件。

例如:

@RestController
public class EventController {
    @GetMapping(path = "/event/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<String> eventStream() {
       // how to create a flux here which I can publish arbitrary events to in future?
    }
}
登录后复制

我在 flux javadocs 中看到了 flux.from(...)flux.generate(...) 方法,但这些方法似乎没有满足我的需要

解决方法

我最终用 sinks.many()

Many<String> emitter = Sinks.many().unicast().onBackpressureBuffer();
Flux<String> flux = emitter.asFlux();
登录后复制

我现在可以了

以上是创建能够在未来发布任意事件的 Flux的详细内容。更多信息请关注PHP中文网其他相关文章!

来源:stackoverflow.com
本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板