当溢出策略为 buffer

问题描述

当我在反应链外调用 subscribe() 时。是不是遵循了spring webflux的溢出策略？

fooRepository.findOne()
    .doOnNext { barRepository.save(bar).subscribe() }
    .flatMap { ... }

我有这种奇怪的行为，它 barRepository.save 有时有效，有时没有错误。我认为它正在被删除。

当服务器繁忙时，doOnNext 内部的 subscribe() 调用可以被丢弃吗？

This post 表示默认溢出策略是 BUFFER。

doOnNext 内部的 subscribe() 调用是否有不同的策略？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）