跳转到主内容
新派编程网 - 新潮编程理念,全新技术课堂!

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

php小编苹果将为大家介绍一个令人兴奋的开发工具——flux。flux 是一个用于构建用户界面的应用程序架构,它专注于单向数据流的概念,使得状态管理变得简单而可预测。通过创建 flux 架构,开发人员可以轻松管理应用程序的状态,并能够在未来发布任意事件,实现更灵活的应用程序开发。flux 的简洁性和可扩展性使得它成为现代前端开发的理想选择。接下来,我们将深入探讨 flux 的工作原理和如何使用它来构建出色的用户界面。 问题内容 我想创建一个自定义
flux
,能够在将来发布任意事件。 例如:
@RestController public class EventController { @GetMapping(path = "/event/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE) public Flux 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 emitter = Sinks.many().unicast().onBackpressureBuffer(); Flux flux = emitter.asFlux();
我现在可以了 通过 emitter.emitnext(...) 通过 emitter.emitcomplete(...)

相关文章