Class AsyncOperationServiceInstanceEventFlowRegistry
java.lang.Object
org.springframework.cloud.servicebroker.service.events.EventFlowRegistry<AsyncOperationServiceInstanceInitializationFlow,AsyncOperationServiceInstanceCompletionFlow,AsyncOperationServiceInstanceErrorFlow,GetLastServiceOperationRequest,GetLastServiceOperationResponse>
org.springframework.cloud.servicebroker.service.events.AsyncOperationServiceInstanceEventFlowRegistry
public class AsyncOperationServiceInstanceEventFlowRegistry
extends EventFlowRegistry<AsyncOperationServiceInstanceInitializationFlow,AsyncOperationServiceInstanceCompletionFlow,AsyncOperationServiceInstanceErrorFlow,GetLastServiceOperationRequest,GetLastServiceOperationResponse>
Event flow registry for asynchronous get last operation requests.
- Author:
- Roy Clarkson
-
Constructor Summary
ConstructorDescriptionAsyncOperationServiceInstanceEventFlowRegistry
(List<AsyncOperationServiceInstanceInitializationFlow> initializationFlows, List<AsyncOperationServiceInstanceCompletionFlow> completionFlows, List<AsyncOperationServiceInstanceErrorFlow> errorFlows) Construct a newAsyncOperationServiceInstanceEventFlowRegistry
. -
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<Void>
getCompletionFlows
(GetLastServiceOperationRequest request, GetLastServiceOperationResponse response) Retrieve the completion flows as a Flux.reactor.core.publisher.Flux<Void>
getErrorFlows
(GetLastServiceOperationRequest request, Throwable t) Retrieve the error flows as a Flux.reactor.core.publisher.Flux<Void>
Retrieve the initialization flows as a Flux.Methods inherited from class org.springframework.cloud.servicebroker.service.events.EventFlowRegistry
addCompletionFlow, addErrorFlow, addInitializationFlow, getCompletionFlowsInternal, getErrorFlowsInternal, getInitializationFlowsInternal
-
Constructor Details
-
AsyncOperationServiceInstanceEventFlowRegistry
public AsyncOperationServiceInstanceEventFlowRegistry(List<AsyncOperationServiceInstanceInitializationFlow> initializationFlows, List<AsyncOperationServiceInstanceCompletionFlow> completionFlows, List<AsyncOperationServiceInstanceErrorFlow> errorFlows) Construct a newAsyncOperationServiceInstanceEventFlowRegistry
.- Parameters:
initializationFlows
- the initialization flowscompletionFlows
- the completion flowserrorFlows
- the error flows
-
-
Method Details
-
getInitializationFlows
public reactor.core.publisher.Flux<Void> getInitializationFlows(GetLastServiceOperationRequest request) Description copied from class:EventFlowRegistry
Retrieve the initialization flows as a Flux.- Specified by:
getInitializationFlows
in classEventFlowRegistry<AsyncOperationServiceInstanceInitializationFlow,
AsyncOperationServiceInstanceCompletionFlow, AsyncOperationServiceInstanceErrorFlow, GetLastServiceOperationRequest, GetLastServiceOperationResponse> - Parameters:
request
- the service broker request- Returns:
- a Flux of initialization flows
-
getCompletionFlows
public reactor.core.publisher.Flux<Void> getCompletionFlows(GetLastServiceOperationRequest request, GetLastServiceOperationResponse response) Description copied from class:EventFlowRegistry
Retrieve the completion flows as a Flux.- Specified by:
getCompletionFlows
in classEventFlowRegistry<AsyncOperationServiceInstanceInitializationFlow,
AsyncOperationServiceInstanceCompletionFlow, AsyncOperationServiceInstanceErrorFlow, GetLastServiceOperationRequest, GetLastServiceOperationResponse> - Parameters:
request
- the service broker requestresponse
- the service broker response- Returns:
- a Flux of completion flows
-
getErrorFlows
public reactor.core.publisher.Flux<Void> getErrorFlows(GetLastServiceOperationRequest request, Throwable t) Description copied from class:EventFlowRegistry
Retrieve the error flows as a Flux.- Specified by:
getErrorFlows
in classEventFlowRegistry<AsyncOperationServiceInstanceInitializationFlow,
AsyncOperationServiceInstanceCompletionFlow, AsyncOperationServiceInstanceErrorFlow, GetLastServiceOperationRequest, GetLastServiceOperationResponse> - Parameters:
request
- the service broker requestt
- the error- Returns:
- a Flux of error flows
-