org.springframework.statemachine.support

Class ReactiveLifecycleManager

java.lang.Object

org.springframework.statemachine.support.ReactiveLifecycleManager

All Implemented Interfaces:

StateMachineReactiveLifecycle

public class ReactiveLifecycleManager
extends java.lang.Object
implements StateMachineReactiveLifecycle

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ReactiveLifecycleManager.LifecycleState

Constructor Summary

Constructors

Constructor and Description
ReactiveLifecycleManager(java.util.function.Supplier<reactor.core.publisher.Mono<java.lang.Void>> preStartRequest, java.util.function.Supplier<reactor.core.publisher.Mono<java.lang.Void>> preStopRequest, java.util.function.Supplier<reactor.core.publisher.Mono<java.lang.Void>> postStartRequest, java.util.function.Supplier<reactor.core.publisher.Mono<java.lang.Void>> postStopRequest)

Method Summary

Modifier and Type	Method and Description
ReactiveLifecycleManager.LifecycleState	getLifecycleState()
boolean	isRunning()
void	setOwner(java.lang.Object owner)
reactor.core.publisher.Mono<java.lang.Void>	startReactively() Starts component reactively.
reactor.core.publisher.Mono<java.lang.Void>	stopReactively() Stops component reactively.
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ReactiveLifecycleManager

public ReactiveLifecycleManager(java.util.function.Supplier<reactor.core.publisher.Mono<java.lang.Void>> preStartRequest,
                                java.util.function.Supplier<reactor.core.publisher.Mono<java.lang.Void>> preStopRequest,
                                java.util.function.Supplier<reactor.core.publisher.Mono<java.lang.Void>> postStartRequest,
                                java.util.function.Supplier<reactor.core.publisher.Mono<java.lang.Void>> postStopRequest)

Method Detail

startReactively

public reactor.core.publisher.Mono<java.lang.Void> startReactively()

Description copied from interface: StateMachineReactiveLifecycle

Starts component reactively.

Specified by:

startReactively in interface StateMachineReactiveLifecycle

Returns:

the mono for completion

stopReactively

public reactor.core.publisher.Mono<java.lang.Void> stopReactively()

Description copied from interface: StateMachineReactiveLifecycle

Stops component reactively.

Specified by:

stopReactively in interface StateMachineReactiveLifecycle

Returns:

the mono for completion

setOwner

public void setOwner(java.lang.Object owner)

getLifecycleState

public ReactiveLifecycleManager.LifecycleState getLifecycleState()

isRunning

public boolean isRunning()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object