Class EventFlowRegistry<I,C,E,R,S>
java.lang.Object
org.springframework.cloud.servicebroker.service.events.EventFlowRegistry<I,C,E,R,S>
- Type Parameters:
I- type of initialization flowC- type of completion flowE- type of error flowR- type of requestS- type of response
- Direct Known Subclasses:
AsyncOperationServiceInstanceBindingEventFlowRegistry,AsyncOperationServiceInstanceEventFlowRegistry,CreateServiceInstanceBindingEventFlowRegistry,CreateServiceInstanceEventFlowRegistry,DeleteServiceInstanceBindingEventFlowRegistry,DeleteServiceInstanceEventFlowRegistry,UpdateServiceInstanceEventFlowRegistry
Abstract class for defining an event flow registry
- Author:
- Roy Clarkson
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<Void>addCompletionFlow(C object) Add a completion flowreactor.core.publisher.Mono<Void>addErrorFlow(E object) Add an error flowreactor.core.publisher.Mono<Void>addInitializationFlow(I object) Add an initialization flowabstract reactor.core.publisher.Flux<Void>getCompletionFlows(R request, S response) Retrieve the completion flows as a Fluxprotected reactor.core.publisher.Flux<C>Merges the completion flows into a Fluxabstract reactor.core.publisher.Flux<Void>getErrorFlows(R request, Throwable t) Retrieve the error flows as a Fluxprotected reactor.core.publisher.Flux<E>Merges the error flows into a Fluxabstract reactor.core.publisher.Flux<Void>getInitializationFlows(R request) Retrieve the initialization flows as a Fluxprotected reactor.core.publisher.Flux<I>Merges the initialization flows into a Flux
-
Constructor Details
-
EventFlowRegistry
Deprecated.Construct a newEventFlowRegistry -
EventFlowRegistry
protected EventFlowRegistry(List<I> initializationFlows, List<C> completionFlows, List<E> errorFlows) Construct a newEventFlowRegistry- Parameters:
initializationFlows- the initialization flowscompletionFlows- the completion flowserrorFlows- the error flows
-
-
Method Details
-
addInitializationFlow
Add an initialization flow- Parameters:
object- the initialization flow- Returns:
- an empty Mono
-
getInitializationFlows
Retrieve the initialization flows as a Flux- Parameters:
request- the service broker request- Returns:
- a Flux of initialization flows
-
getInitializationFlowsInternal
Merges the initialization flows into a Flux- Returns:
- a Flux of initialization flows
-
addCompletionFlow
Add a completion flow- Parameters:
object- the completion flow- Returns:
- an empty Mono
-
getCompletionFlows
Retrieve the completion flows as a Flux- Parameters:
request- the service broker requestresponse- the service broker response- Returns:
- a Flux of completion flows
-
getCompletionFlowsInternal
Merges the completion flows into a Flux- Returns:
- a Flux of completion flows
-
addErrorFlow
Add an error flow- Parameters:
object- the error flow- Returns:
- an empty Mono
-
getErrorFlows
Retrieve the error flows as a Flux- Parameters:
request- the service broker requestt- the error- Returns:
- a Flux of error flows
-
getErrorFlowsInternal
Merges the error flows into a Flux- Returns:
- a Flux of error flows
-