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

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();

我现在可以了

• 通过 emitter.emitnext(...)
• 通过emitter.emitcomplete(...)

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