如何测试通量像通量

Question

我有这个界面：

interface PageRepository {
  fun findAll(): Flux<Flux<Page>>
}

我想测试它的实现，但我得到：java.lang.AssertionError：期望期望下一步（FLuxIterable）失败（期望值：FLuxIterable；实际值：Unicast处理器）

在测试中，我使用预期下一步（）：

 repository
      .findAll()
      .test()
      .expectSubscription()
      .expectNext(listOf(page(PATH_1), page(PATH_2)).toFlux())
      .expectNext(listOf(page(PATH_3), page(PATH_4)).toFlux())
      .expectNext(listOf(page(PATH_5)).toFlux())
      .verifyComplete()

我错过了什么

Answer 1

expectNext use等于，这就是为什么即使两个通量包含相同的数据，但这两个通量都不相同。

您可以执行以下操作：

repository().findAll()
        .test()
        .expectSubscription()
        .assertNext {
            it.test()
                    .expectNext(page(PATH_1), page(PATH_2))
                    .verifyComplete()
        }.assertNext {
            it.test()
                    .expectNext(page(PATH_3), page(PATH_4))
                    .verifyComplete()
        }.assertNext {
            it.test()
                    .expectNext(page(PATH_5))
                    .verifyComplete()
        }.verifyComplete()

我不知道是否有更好的选择，但这应该行得通。