在webflux序列中引发错误/断言？

Question

假设我有以下webflux片段：

.map(str -> str.split(","))
.OnErrorResume(...)

我想确保split返回一个正好包含x个项目的数组。否则我想进入错误恢复。有没有webflux-y方法可以做到这一点filter只会删除坏项，但这不是我想要的。

我是否需要将地图展开为类似以下内容：

{
  String[] arr = str.split(",");
  if (arr.length != 3)
     return Mono.error();
  return arr;
}

还是有什么内在的？

Answer 1

你试过句柄方法吗？

.map(str -> str.split(","))
.<String[]>handle((arr, sink) -> {
    if (arr.length == x)
         sink.next(arr);
    else
         sink.error(new ArrayLengthException());
   })
.onErrorResume(err -> Mono.just(...));