禁止在长沙发中插入内容

Question

我正在编写一个测试，我需要在实际运行任何测试之前在我的长椅式存储桶中插入一些文档（假设为10）。因此，我有一个用@BeforeAll注释的方法，该方法试图使这些文档不满意。现在，当我尝试运行测试时，该测试失败了，因为那时文档还没有持久化。为了等待这些文档被插入，我正在做类似的事情-

    Flux.fromIterable(couchDocs)
        .map(couchDoc -> bucket.upsert(couchDoc, persistTo)
        .collectList()
        .block();

但是仍然在运行测试时，我可以看到当时文档尚未持久并且断言失败。我在这里想念什么吗？

Answer 1

使用。flatMap代替。map。您的内部流没有被订阅。