org.axonframework.queryhandling

Interface SubscriptionQueryResult<I,U>

All Superinterfaces:

AutoCloseable, Registration

All Known Implementing Classes:

AxonServerSubscriptionQueryResult, DefaultSubscriptionQueryResult, DeserializedResult, DisposableResult

public interface SubscriptionQueryResult<I,U>
extends Registration

Result of the subscription query. It contains publishers for initial result and incremental updates. Until there is a subscription to the publisher, nothing happens.

Since:

3.3

Author:

Milan Savic

See Also:

QueryBus.subscriptionQuery(SubscriptionQueryMessage, int)

Method Summary

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.

Methods inherited from interface org.axonframework.common.Registration

cancel, close

Method Detail

initialResult

reactor.core.publisher.Mono<I> initialResult()

Subscribing to this mono will trigger invocation of query handler. The return value of that query handler will be passed to the mono, once it's ready.

Returns:

the mono representing the initial result

updates

reactor.core.publisher.Flux<U> updates()

When there is an update to the subscription query, it will be emitted to this flux.

Returns:

the flux representing the incremental updates

handle

default void handle(Consumer<? super I> initialResultConsumer,
                    Consumer<? super U> updateConsumer)

Delegates handling of initial result and incremental updates to the provided consumers. Subscription to the incremental updates is done after the initial result is retrieved and its consumer is invoked. If anything goes wrong during invoking or consuming initial result or incremental updates, subscription is cancelled.

Parameters:

initialResultConsumer - The consumer to be invoked when the initial result is retrieved

updateConsumer - The consumer to be invoked when incremental updates are emitted