public class UpdateHandlerRegistration<U> extends Object
Flux
with updates and Registration
to be
cancelled when we're no longer interested in updates.Constructor and Description |
---|
UpdateHandlerRegistration(Registration registration,
reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> updates,
Runnable completeHandler)
|
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.
|
public UpdateHandlerRegistration(Registration registration, reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> updates, Runnable completeHandler)
registration
- used to cancel the registrationupdates
- used to subscribe to updates streamcompleteHandler
- handler invoked on complete()
public Registration getRegistration()
public reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> getUpdates()
Flux
for subscribing to the update streampublic void complete()
getUpdates()
Flux
. The consumer can use this method to indicate it is no longer
interested in updates. This operation automatically closes the registration
too.Copyright © 2010–2023. All rights reserved.