Akka 中等效于 Reactor 的 Flux.switchOnFirst 的方法:Source.preMaterialize
在 Akka 中,与 Reactor 的 Flux.switchOnFirst 等效的方法是 Source.preMaterialize。
Source.preMaterialize 方法返回一个 Pair 对象,其中第一个值是 Source 的 MaterializedValue,第二个值是 Source 本身。通过调用 preMaterialize 方法,可以在 Source 创建之前获取到 MaterializedValue。类似地,Flux.switchOnFirst 方法可以在 Flux 创建之前获取到第一个元素,然后根据第一个元素的类型来决定如何处理后续元素。
原文地址: https://www.cveoy.top/t/topic/lIIH 著作权归作者所有。请勿转载和采集!