public class AsyncOperationServiceInstanceEventFlowRegistry extends EventFlowRegistry<AsyncOperationServiceInstanceInitializationFlow,AsyncOperationServiceInstanceCompletionFlow,AsyncOperationServiceInstanceErrorFlow,GetLastServiceOperationRequest,GetLastServiceOperationResponse>
Constructor and Description |
---|
AsyncOperationServiceInstanceEventFlowRegistry()
Deprecated.
|
AsyncOperationServiceInstanceEventFlowRegistry(List<AsyncOperationServiceInstanceInitializationFlow> initializationFlows,
List<AsyncOperationServiceInstanceCompletionFlow> completionFlows,
List<AsyncOperationServiceInstanceErrorFlow> errorFlows)
Construct a new
AsyncOperationServiceInstanceEventFlowRegistry |
Modifier and Type | Method and Description |
---|---|
reactor.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> |
getInitializationFlows(GetLastServiceOperationRequest request)
Retrieve the initialization flows as a Flux
|
addCompletionFlow, addErrorFlow, addInitializationFlow, getCompletionFlowsInternal, getErrorFlowsInternal, getInitializationFlowsInternal
@Deprecated public AsyncOperationServiceInstanceEventFlowRegistry()
AsyncOperationServiceInstanceEventFlowRegistry
public AsyncOperationServiceInstanceEventFlowRegistry(List<AsyncOperationServiceInstanceInitializationFlow> initializationFlows, List<AsyncOperationServiceInstanceCompletionFlow> completionFlows, List<AsyncOperationServiceInstanceErrorFlow> errorFlows)
AsyncOperationServiceInstanceEventFlowRegistry
initializationFlows
- the initialization flowscompletionFlows
- the completion flowserrorFlows
- the error flowspublic reactor.core.publisher.Flux<Void> getInitializationFlows(GetLastServiceOperationRequest request)
EventFlowRegistry
getInitializationFlows
in class EventFlowRegistry<AsyncOperationServiceInstanceInitializationFlow,AsyncOperationServiceInstanceCompletionFlow,AsyncOperationServiceInstanceErrorFlow,GetLastServiceOperationRequest,GetLastServiceOperationResponse>
request
- the service broker requestpublic reactor.core.publisher.Flux<Void> getCompletionFlows(GetLastServiceOperationRequest request, GetLastServiceOperationResponse response)
EventFlowRegistry
getCompletionFlows
in class EventFlowRegistry<AsyncOperationServiceInstanceInitializationFlow,AsyncOperationServiceInstanceCompletionFlow,AsyncOperationServiceInstanceErrorFlow,GetLastServiceOperationRequest,GetLastServiceOperationResponse>
request
- the service broker requestresponse
- the service broker responsepublic reactor.core.publisher.Flux<Void> getErrorFlows(GetLastServiceOperationRequest request, Throwable t)
EventFlowRegistry
getErrorFlows
in class EventFlowRegistry<AsyncOperationServiceInstanceInitializationFlow,AsyncOperationServiceInstanceCompletionFlow,AsyncOperationServiceInstanceErrorFlow,GetLastServiceOperationRequest,GetLastServiceOperationResponse>
request
- the service broker requestt
- the error