org.springframework.cloud.servicebroker.service.events

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

Constructors

Constructor and Description
AsyncOperationServiceInstanceEventFlowRegistry()

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<Void>	getCompletionFlows(GetLastServiceOperationRequest request, GetLastServiceOperationResponse response)
reactor.core.publisher.Flux<Void>	getErrorFlows(GetLastServiceOperationRequest request, Throwable t)
reactor.core.publisher.Flux<Void>	getInitializationFlows(GetLastServiceOperationRequest request)

Methods inherited from class org.springframework.cloud.servicebroker.service.events.EventFlowRegistry

addCompletionFlow, addErrorFlow, addInitializationFlow

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncOperationServiceInstanceEventFlowRegistry

public AsyncOperationServiceInstanceEventFlowRegistry()

Method Detail

getInitializationFlows

public reactor.core.publisher.Flux<Void> getInitializationFlows(GetLastServiceOperationRequest request)

Specified by:

getInitializationFlows in class EventFlowRegistry<AsyncOperationServiceInstanceInitializationFlow,AsyncOperationServiceInstanceCompletionFlow,AsyncOperationServiceInstanceErrorFlow,GetLastServiceOperationRequest,GetLastServiceOperationResponse>

getCompletionFlows

public reactor.core.publisher.Flux<Void> getCompletionFlows(GetLastServiceOperationRequest request,
                                                            GetLastServiceOperationResponse response)

Specified by:

getCompletionFlows in class EventFlowRegistry<AsyncOperationServiceInstanceInitializationFlow,AsyncOperationServiceInstanceCompletionFlow,AsyncOperationServiceInstanceErrorFlow,GetLastServiceOperationRequest,GetLastServiceOperationResponse>

getErrorFlows

public reactor.core.publisher.Flux<Void> getErrorFlows(GetLastServiceOperationRequest request,
                                                       Throwable t)

Specified by:

getErrorFlows in class EventFlowRegistry<AsyncOperationServiceInstanceInitializationFlow,AsyncOperationServiceInstanceCompletionFlow,AsyncOperationServiceInstanceErrorFlow,GetLastServiceOperationRequest,GetLastServiceOperationResponse>