This commit is contained in:
committed by
Mahmoud Ben Hassine
parent
88ac89d1eb
commit
f31d2b1a77
@@ -125,7 +125,7 @@ public class ReactiveStateMachineExecutor<S, E> extends LifecycleObjectSupport i
|
||||
Mono<Void> mono = startTriggers();
|
||||
|
||||
if (triggerDisposable == null) {
|
||||
triggerDisposable = triggerFlux.subscribe();
|
||||
triggerDisposable = triggerFlux.contextCapture().subscribe();
|
||||
}
|
||||
|
||||
if (!initialHandled.getAndSet(true)) {
|
||||
|
||||
Reference in New Issue
Block a user