search

ru-fix / completable-reactor

CompletableReactor framework makes it easier to create business flows that have concurrently running parts and complex execution branching.
https://ru-fix.github.io/completable-reactor
MIT License
12 stars 2 forks source link

Reactor hangs when an exception is thrown in a merger #35

Open aekrylov opened 4 years ago

aekrylov commented 4 years ago

The following code will wait indefinitely when an exception is thrown in a merger

reactor.submit(payload)
            .resultFuture
            .await()

The exception can be seen in logs, but still await does not seem to complete

(will provide more details later)