I
- The type of initial resultU
- The type of incremental updatespublic class DefaultSubscriptionQueryResult<I,U> extends Object implements SubscriptionQueryResult<I,U>
SubscriptionQueryResult
.Constructor and Description |
---|
DefaultSubscriptionQueryResult(reactor.core.publisher.Mono<I> initialResult,
reactor.core.publisher.Flux<U> updates,
Registration registrationDelegate)
Initializes the result with mono and flux used for result retrieval.
|
Modifier and Type | Method and Description |
---|---|
boolean |
cancel()
Cancels this Registration.
|
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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handle
close
public DefaultSubscriptionQueryResult(reactor.core.publisher.Mono<I> initialResult, reactor.core.publisher.Flux<U> updates, Registration registrationDelegate)
initialResult
- mono representing initial resultupdates
- flux representing incremental updatesregistrationDelegate
- delegate which cancels the registration of this resultpublic reactor.core.publisher.Mono<I> initialResult()
SubscriptionQueryResult
initialResult
in interface SubscriptionQueryResult<I,U>
public reactor.core.publisher.Flux<U> updates()
SubscriptionQueryResult
updates
in interface SubscriptionQueryResult<I,U>
public boolean cancel()
Registration
cancel
in interface Registration
true
if this handler is successfully deregistered, false
if this handler
was not currently registered.Copyright © 2010–2023. All rights reserved.