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)
|
Modifier and Type | Method and Description |
---|---|
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)
registration
- used to cancel the registrationupdates
- used to subscribe to updates streampublic Registration getRegistration()
public reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> getUpdates()
Flux
for subscribing to the update streamCopyright © 2010–2019. All rights reserved.