public interface SubscriptionQueryResult<I,U> extends Registration
QueryBus.subscriptionQuery(SubscriptionQueryMessage, SubscriptionQueryBackpressure, int)
Modifier and Type | Method and Description |
---|---|
default void |
handle(Consumer<? super I> initialResultConsumer,
Consumer<? super U> updateConsumer)
Delegates handling of initial result and incremental updates to the provided consumers.
|
reactor.core.publisher.Mono<I> |
initialResult()
Subscribing to this mono will trigger invocation of query handler.
|
reactor.core.publisher.Flux<U> |
updates()
When there is an update to the subscription query, it will be emitted to this flux.
|
cancel, close
reactor.core.publisher.Mono<I> initialResult()
reactor.core.publisher.Flux<U> updates()
default void handle(Consumer<? super I> initialResultConsumer, Consumer<? super U> updateConsumer)
initialResultConsumer
- The consumer to be invoked when the initial result is retrievedupdateConsumer
- The consumer to be invoked when incremental updates are emittedCopyright © 2010–2020. All rights reserved.