在junit测试中，Reactor switchifempty的行为不符合预期

Question

我正在为下面提供的方法编写测试。`

class ScrapedRecipeCache @Autowired constructor(private val cache: RecipeScrapingCacheService,
private val recipeService: RecipeService) : ScrapedRecipeProvider {
override fun provide(request: ScrapingRequest): Flux<ScrapedRecipe> =
cache.retrieve(request.link)
.doOnNext { println(it) }
.flatMap { (link, _, recipeHash, error) ->
recipeService.findByHash(recipeHash)
.map { ScrapedRecipe(it, link, error)}
.switchIfEmpty(cache.remove(request.link).then(Mono.empty()))
}
.flux()

}

`测试如下：

private val recipeFetched = Recipe("Tortellini", RecipeDifficulty.EASY, 15.0)
val cacheContents = RecipeScrapingResource("www.google.com", ScrapingOrigin.JAMIE_OLIVER, recipeFetched.hash,
mutableListOf(
pl.goolash.core.Exception("aa", ErrorType.WARNING, LocalDateTime.MIN)
))
val request = ScrapingRequest("www.google.com", ScrapingOrigin.JAMIE_OLIVER, 4)
@BeforeEach
fun setUp() {
given(cache.retrieve("www.google.com")).willReturn(Mono.just(cacheContents))
given(recipeService.findByHash(recipeFetched.hash)).willReturn(Mono.just(recipeFetched))
}
@Test
@DisplayName("Then return data fetched from service and don't delete cache")
fun test() {
cacheFacade.provide(request)
.test()
.expectNext(ScrapedRecipe(recipeFetched, "www.google.com", cacheContents.error!!))
.expectComplete()
.verify()
BDDMockito.verify(cache, BDDMockito.never()).remove(request.link)
}

测试失败，因为调用了cache.remove(request.link)。据我所知(或从我设法从文档中收集到的)，switchIfEmpty，只应在recipeService.findByHash返回Mono.empty()时触发。然而，调试器显示它返回Mono.just(fetchedRecipe)的模拟值。

有趣的是，当我更换时

.switchIfEmpty(cache.remove(request.link).then(Mono.empty()))

带有

.switchIfEmpty(Mono.just(1).doOnNext{println("weeee")}.then(Mono.empty()))

然后weee不会被打印，因此它的行为与预期的一样，也就是说switchIfEmpty没有被激发。

此外，测试的问题在集成测试中正常运行，并且不会清除缓存。

反应堆版本：3.1.0-RC1其他值得注意的细节：Spring Boot 2.0.0-M4，Mockito内核：2.10，junit 5，项目用kotlin 编写

问题是，有人认为这有什么不对吗？因为我花了两天的时间，仍然不知道为什么这种行为如此怪异。

Answer 1

最后我发现了如何实现这一点。

为了补救：

override fun provide(request: ScrapingRequest): Flux<ScrapedRecipe> =
cache.retrieve(request.link)
.flatMap { (link, _, recipeHash, error) ->
recipeService.findByHash(recipeHash)
.map { ScrapedRecipe(it, link, error) }
.switchIfEmpty(Mono.just(1)
.flatMap { cache.remove(request.link) }
.then(Mono.empty()))
}
.flux()

您可以看到使用flatMap执行异步工作是如何完成这项工作的，即使这不是最整洁的实现，它也向我揭示了隐藏在这里的一个非常有趣的机制。