Package org.springframework.cloud.servicebroker.service.events

Class AsyncOperationServiceInstanceBindingEventFlowRegistry

java.lang.Object

org.springframework.cloud.servicebroker.service.events.EventFlowRegistry<AsyncOperationServiceInstanceBindingInitializationFlow,AsyncOperationServiceInstanceBindingCompletionFlow,AsyncOperationServiceInstanceBindingErrorFlow,GetLastServiceBindingOperationRequest,GetLastServiceBindingOperationResponse>

org.springframework.cloud.servicebroker.service.events.AsyncOperationServiceInstanceBindingEventFlowRegistry

public class AsyncOperationServiceInstanceBindingEventFlowRegistry
extends EventFlowRegistry<AsyncOperationServiceInstanceBindingInitializationFlow,AsyncOperationServiceInstanceBindingCompletionFlow,AsyncOperationServiceInstanceBindingErrorFlow,GetLastServiceBindingOperationRequest,GetLastServiceBindingOperationResponse>

Event flow registry for asynchronous get last binding operation requests.

Author:

Ilya Vy

Constructor Summary

Constructors

Constructor	Description
AsyncOperationServiceInstanceBindingEventFlowRegistry(List<AsyncOperationServiceInstanceBindingInitializationFlow> initializationFlows, List<AsyncOperationServiceInstanceBindingCompletionFlow> completionFlows, List<AsyncOperationServiceInstanceBindingErrorFlow> errorFlows)	Construct a new AsyncOperationServiceInstanceBindingEventFlowRegistry.

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<Void>	getCompletionFlows(GetLastServiceBindingOperationRequest request, GetLastServiceBindingOperationResponse response)	Retrieve the completion flows as a Flux.
reactor.core.publisher.Flux<Void>	getErrorFlows(GetLastServiceBindingOperationRequest request, Throwable t)	Retrieve the error flows as a Flux.
reactor.core.publisher.Flux<Void>	getInitializationFlows(GetLastServiceBindingOperationRequest request)	Retrieve the initialization flows as a Flux.

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

addCompletionFlow, addErrorFlow, addInitializationFlow, getCompletionFlowsInternal, getErrorFlowsInternal, getInitializationFlowsInternal

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncOperationServiceInstanceBindingEventFlowRegistry

public AsyncOperationServiceInstanceBindingEventFlowRegistry(List<AsyncOperationServiceInstanceBindingInitializationFlow> initializationFlows,
 List<AsyncOperationServiceInstanceBindingCompletionFlow> completionFlows,
 List<AsyncOperationServiceInstanceBindingErrorFlow> errorFlows)

Construct a new AsyncOperationServiceInstanceBindingEventFlowRegistry.

Parameters:

initializationFlows - the initialization flows

completionFlows - the completion flows

errorFlows - the error flows

Method Details

getInitializationFlows

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

Description copied from class: EventFlowRegistry

Retrieve the initialization flows as a Flux.

Specified by:

getInitializationFlows in class EventFlowRegistry<AsyncOperationServiceInstanceBindingInitializationFlow,AsyncOperationServiceInstanceBindingCompletionFlow,AsyncOperationServiceInstanceBindingErrorFlow,GetLastServiceBindingOperationRequest,GetLastServiceBindingOperationResponse>

Parameters:

request - the service broker request

Returns:

a Flux of initialization flows

getCompletionFlows

public reactor.core.publisher.Flux<Void> getCompletionFlows(GetLastServiceBindingOperationRequest request,
 GetLastServiceBindingOperationResponse response)

Description copied from class: EventFlowRegistry

Retrieve the completion flows as a Flux.

Specified by:

getCompletionFlows in class EventFlowRegistry<AsyncOperationServiceInstanceBindingInitializationFlow,AsyncOperationServiceInstanceBindingCompletionFlow,AsyncOperationServiceInstanceBindingErrorFlow,GetLastServiceBindingOperationRequest,GetLastServiceBindingOperationResponse>

Parameters:

request - the service broker request

response - the service broker response

Returns:

a Flux of completion flows

getErrorFlows

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

Description copied from class: EventFlowRegistry

Retrieve the error flows as a Flux.

Specified by:

getErrorFlows in class EventFlowRegistry<AsyncOperationServiceInstanceBindingInitializationFlow,AsyncOperationServiceInstanceBindingCompletionFlow,AsyncOperationServiceInstanceBindingErrorFlow,GetLastServiceBindingOperationRequest,GetLastServiceBindingOperationResponse>

Parameters:

request - the service broker request

t - the error

Returns:

a Flux of error flows