Как мне проверить обратное давление на интервале потока? - PullRequest
Новая
       8

Как мне проверить обратное давление на интервале потока?

0 голосов
/ 16 января 2020

У меня есть метод со следующим кодом: 

 override fun lookup(): Flux<Thing> {
    return Flux.interval(Duration.ofSeconds(10)).flatMap {
        repository.lookup()
    }.onErrorResume {
        Flux.empty<Thing>()
    }
}

, и иногда я вижу, что вызов хранилища занимает больше времени, чем интервал. Я знаю, что добавление .onBackpressureDrop() к потоку интервалов исправит возникающее исключение.

Однако я пытаюсь протестировать этот код и не могу найти хорошую технику, используя TestPublisher и StepVerifier. Каков наилучший или рекомендуемый способ проверки этого сценария?

...