Почему реактор.core.publisher.Hooks.onOperatorDebug () исправляет юнит-тест? - PullRequest
Новая
       14

Почему реактор.core.publisher.Hooks.onOperatorDebug () исправляет юнит-тест?

0 голосов
/ 24 декабря 2018

Когда я запускаю модульный тест, вызывающий метод, возвращающий Flux, я получаю следующее StackTrace: 

java.lang.ClassCastException: reactor.core.publisher.FluxMap$MapSubscriber cannot be cast to reactor.core.Fuseable$QueueSubscription

    at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onSubscribe(FluxMapFuseable.java:89)
    at reactor.core.publisher.FluxMap$MapSubscriber.onSubscribe(FluxMap.java:86)
    at reactor.core.publisher.FluxSwitchMap$SwitchMapMain.onSubscribe(FluxSwitchMap.java:191)
    at reactor.core.publisher.FluxCombineLatest.subscribe(FluxCombineLatest.java:174)
    at reactor.core.publisher.FluxSwitchMap.subscribe(FluxSwitchMap.java:84)
    at reactor.core.publisher.FluxMap.subscribe(FluxMap.java:62)
    at reactor.core.publisher.FluxCombineLatest.subscribe(FluxCombineLatest.java:164)
    at reactor.core.publisher.FluxMapFuseable.subscribe(FluxMapFuseable.java:63)
    at reactor.core.publisher.Flux.subscribe(Flux.java:6877)

    ...

    at reactor.core.publisher.FluxMapFuseable.subscribe(FluxMapFuseable.java:63)
    at reactor.core.publisher.FluxFlatMap.subscribe(FluxFlatMap.java:97)
    at reactor.core.publisher.FluxOnErrorResume.subscribe(FluxOnErrorResume.java:47)
    at reactor.core.publisher.FluxOnErrorResume.subscribe(FluxOnErrorResume.java:47)
    at reactor.core.publisher.Flux.blockFirst(Flux.java:2012)

В надежде получить дополнительную информацию, я добавляю Hooks.onOperatorDebug() непосредственно перед вызовом реактивного метода,Но вместо получения дополнительной информации юнит-тест завершается успешно.Как это возможно?

...