Мы используем реактор Кафка. Метод KafkaReceive.receive () возвращает FluxAutoConnectFuseable. У меня есть один сценарий, где либо он не должен был испускать какой-либо элемент, либо, если он испускал несколько элементов, тогда он не должен иметь ожидаемого значения. Как я могу проверить его, используя Step Verifier или любой другой подход?
FluxAutoConnectFuseable внутренне использует ConnectableFlux в качестве источника, который не предоставляется вне какого-либо метода.
Так как я хочу сделать это как часть тест, я в порядке, блокируя его, чтобы получить внутренние значения. Пожалуйста, предложите.