I - type of initialization flowC - type of completion flowE - type of error flowR - type of requestS - type of responsepublic abstract class EventFlowRegistry<I,C,E,R,S> extends Object
| Modifier | Constructor and Description |
|---|---|
|
EventFlowRegistry()
Deprecated.
|
protected |
EventFlowRegistry(List<I> initializationFlows,
List<C> completionFlows,
List<E> errorFlows)
Construct a new
EventFlowRegistry |
| Modifier and Type | Method and Description |
|---|---|
reactor.core.publisher.Mono<Void> |
addCompletionFlow(C object)
Add a completion flow
|
reactor.core.publisher.Mono<Void> |
addErrorFlow(E object)
Add an error flow
|
reactor.core.publisher.Mono<Void> |
addInitializationFlow(I object)
Add an initialization flow
|
abstract reactor.core.publisher.Flux<Void> |
getCompletionFlows(R request,
S response)
Retrieve the completion flows as a Flux
|
protected reactor.core.publisher.Flux<C> |
getCompletionFlowsInternal()
Merges the completion flows into a Flux
|
abstract reactor.core.publisher.Flux<Void> |
getErrorFlows(R request,
Throwable t)
Retrieve the error flows as a Flux
|
protected reactor.core.publisher.Flux<E> |
getErrorFlowsInternal()
Merges the error flows into a Flux
|
abstract reactor.core.publisher.Flux<Void> |
getInitializationFlows(R request)
Retrieve the initialization flows as a Flux
|
protected reactor.core.publisher.Flux<I> |
getInitializationFlowsInternal()
Merges the initialization flows into a Flux
|
@Deprecated public EventFlowRegistry()
EventFlowRegistrypublic reactor.core.publisher.Mono<Void> addInitializationFlow(I object)
object - the initialization flowpublic abstract reactor.core.publisher.Flux<Void> getInitializationFlows(R request)
request - the service broker requestprotected reactor.core.publisher.Flux<I> getInitializationFlowsInternal()
public reactor.core.publisher.Mono<Void> addCompletionFlow(C object)
object - the completion flowpublic abstract reactor.core.publisher.Flux<Void> getCompletionFlows(R request, S response)
request - the service broker requestresponse - the service broker responseprotected reactor.core.publisher.Flux<C> getCompletionFlowsInternal()
public reactor.core.publisher.Mono<Void> addErrorFlow(E object)
object - the error flowpublic abstract reactor.core.publisher.Flux<Void> getErrorFlows(R request, Throwable t)
request - the service broker requestt - the errorprotected reactor.core.publisher.Flux<E> getErrorFlowsInternal()