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()
EventFlowRegistry
public 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()