Блокировка upsert в диване - PullRequest
Новая
       11

Блокировка upsert в диване

1 голос
/ 03 февраля 2020

Я пишу тест, в котором мне нужно поместить некоторые документы (скажем, 10) в мое ведро на диване перед тем, как запускать какие-либо тесты. Итак, у меня есть метод, аннотированный @BeforeAll, который пытается расстроить эти документы. Теперь, когда я пытаюсь запустить тест, тест не проходит, потому что документы не были сохранены к тому времени. Чтобы дождаться вставки этих документов, я делаю что-то вроде этого - 


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

Но все же, когда я запускаю тест, я вижу, что документы не были сохранены к тому времени, и утверждения не выполняются. Я что-то здесь упускаю?

1 Ответ

3 голосов
/ 03 февраля 2020

Используйте. flatMap вместо. map. Ваш внутренний поток не подписан.

...