org.springframework.cloud.servicebroker.service.events

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 flow

C - type of completion flow

E - type of error flow

R - type of request

S - type of response

Direct Known Subclasses:

AsyncOperationServiceInstanceEventFlowRegistry, CreateServiceInstanceBindingEventFlowRegistry, CreateServiceInstanceEventFlowRegistry, DeleteServiceInstanceBindingEventFlowRegistry, DeleteServiceInstanceEventFlowRegistry, UpdateServiceInstanceEventFlowRegistry

public abstract class EventFlowRegistry<I,C,E,R,S>
extends Object

Abstract class for defining an event flow registry

Author:

Roy Clarkson

Constructor Summary

Constructors

Constructor and Description
EventFlowRegistry()

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Mono<Void>	addCompletionFlow(C object)
reactor.core.publisher.Mono<Void>	addErrorFlow(E object)
reactor.core.publisher.Mono<Void>	addInitializationFlow(I object)
abstract reactor.core.publisher.Flux<Void>	getCompletionFlows(R request, S response)
abstract reactor.core.publisher.Flux<Void>	getErrorFlows(R request, Throwable t)
abstract reactor.core.publisher.Flux<Void>	getInitializationFlows(R request)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventFlowRegistry

public EventFlowRegistry()

Method Detail

addInitializationFlow

public reactor.core.publisher.Mono<Void> addInitializationFlow(I object)

getInitializationFlows

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

addCompletionFlow

public reactor.core.publisher.Mono<Void> addCompletionFlow(C object)

getCompletionFlows

public abstract reactor.core.publisher.Flux<Void> getCompletionFlows(R request,
                                                                     S response)

addErrorFlow

public reactor.core.publisher.Mono<Void> addErrorFlow(E object)

getErrorFlows

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