創建能夠在未來發布任意事件的 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中文網其他相關文章！