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()
Manyemitter = Sinks.many().unicast().onBackpressureBuffer(); Flux flux = emitter.asFlux();
我现在可以了










