java - next() 与 Single() 哪个有效？

Question

我想从助焊剂转换为单声道。但是，我无法决定何时使用 single() 或 next() 并且不知道哪个更有效？

Flux<String> optionalIdsFlux = Flux
    .fromIterable(result.getPersonalizationEntity())
    .filter(i -> i.getKey().equals(PERSONALIZATION_KEY))
    .next()  //  or single() ??
    .map(DataEntity::getValue)
    .flatMapMany(Flux::fromIterable);`

Answer 1

它们实际上是完全不同的。 next() 获取发出的第一个值并随后取消订阅。

另一方面，

single() 期望首先发出一个元素。如果情况并非如此，并且发出零个或多个元素，则会发出错误信号。

选择哪一个取决于您的用例。如果保证源只发出一个元素，那么您可以使用 single()。否则使用next()。