`.actionFunction(context -> {
Flux businessFlux = Flux.just("A", "B", "C")
.delayElements(Duration.ofMillis(1000))
.map(item -> {
if ("B".equals(item)) {
RuntimeException err = new RuntimeException("test one error");

              throw err;            }            return item;          });      return businessFlux.then();    })`

The result of stateMachine.sendEvent is always ACCEPTED. Why is this happening and how can I handle it?