报告长的 Reactive Streams 转换链。

每个运算符方法调用,例如 map()filter(),都会为这些运算符创建一些对象。 在每个订阅上对于每个流元素调用一长串运算符可能会导致性能开销。 为避免这种情况,请尽可能将一长串调用合并为一个操作员调用。

示例:


Flux.just(1, 2, 3)
        .map(it -> it + 1)
        .map(it -> it + 2)
        .map(it -> it + 3)

在应用快速修复后:


Flux.just(1, 2, 3)
        .map(it -> it + 1 + 2 + 3)

2019.3 的新功能