org.axonframework.queryhandling

Class UpdateHandlerRegistration<U>

java.lang.Object

org.axonframework.queryhandling.UpdateHandlerRegistration<U>

public class UpdateHandlerRegistration<U>
extends Object

Result of registering an Update Handler. Contains a Flux with updates and Registration to be cancelled when we're no longer interested in updates.

Since:

4.0

Author:

Milan Savic

Constructor Summary

Constructors

Constructor and Description
UpdateHandlerRegistration(Registration registration, reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> updates, Runnable completeHandler) Constructs a UpdateHandlerRegistration with given registration and updates.

Method Summary

Modifier and Type	Method and Description
void	complete() Completes the getUpdates() Flux.
Registration	getRegistration() Gets the registration.
reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>>	getUpdates() Gets the updates.

Methods inherited from class java.lang.Object

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

Constructor Detail

UpdateHandlerRegistration

public UpdateHandlerRegistration(Registration registration,
                                 reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> updates,
                                 Runnable completeHandler)

Constructs a UpdateHandlerRegistration with given registration and updates.

Parameters:

registration - used to cancel the registration

updates - used to subscribe to updates stream

completeHandler - handler invoked on complete()

Method Detail

getRegistration

public Registration getRegistration()

Gets the registration.

Returns:

the registration used for cancellation of updates

getUpdates

public reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> getUpdates()

Gets the updates.

Returns:

a Flux for subscribing to the update stream

complete

public void complete()

Completes the getUpdates() Flux. The consumer can use this method to indicate it is no longer interested in updates.