Tho*_*Lee 5 java reactive-programming project-reactor
我有以下代码:
Flux.create(sink -> ..., FluxSink.OverflowStrategy.LATEST)
...
.onBackpressureLatest()
.subscribe();
Run Code Online (Sandbox Code Playgroud)
FluxSink.OverflowStrategy.LATEST如果我指定vs. ,Flux 行为有什么区别.onBackpressureLatest()?
如果我指定,例如,两者FluxSink.OverflowStrategy.LATEST和.onBackpressureBuffer(),它会做什么?
| 归档时间: |
|
| 查看次数: |
703 次 |
| 最近记录: |