Package org.springframework.statemachine.support

Class ReactiveLifecycleManager

java.lang.Object

org.springframework.statemachine.support.ReactiveLifecycleManager

All Implemented Interfaces:

StateMachineReactiveLifecycle

public class ReactiveLifecycleManager
extends Object
implements StateMachineReactiveLifecycle

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ReactiveLifecycleManager.LifecycleState

Constructor Summary

Constructors

Constructor	Description
ReactiveLifecycleManager(Supplier<reactor.core.publisher.Mono<Void>> preStartRequest, Supplier<reactor.core.publisher.Mono<Void>> preStopRequest, Supplier<reactor.core.publisher.Mono<Void>> postStartRequest, Supplier<reactor.core.publisher.Mono<Void>> postStopRequest)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

ReactiveLifecycleManager

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

Method Details

startReactively

public reactor.core.publisher.Mono<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<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(Object owner)

getLifecycleState

public ReactiveLifecycleManager.LifecycleState getLifecycleState()

isRunning

public boolean isRunning()

toString

public String toString()

Overrides:

toString in class Object