public class DeserializedResult<I,U> extends Object implements SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>
Constructor and Description |
---|
DeserializedResult(SubscriptionQueryResult<QueryResponse,QueryUpdate> delegate,
SubscriptionMessageSerializer serializer) |
Modifier and Type | Method and Description |
---|---|
boolean |
cancel()
Cancels this Registration.
|
reactor.core.publisher.Mono<QueryResponseMessage<I>> |
initialResult()
Subscribing to this mono will trigger invocation of query handler.
|
reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<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 DeserializedResult(SubscriptionQueryResult<QueryResponse,QueryUpdate> delegate, SubscriptionMessageSerializer serializer)
public reactor.core.publisher.Mono<QueryResponseMessage<I>> initialResult()
SubscriptionQueryResult
initialResult
in interface SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>
public reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> updates()
SubscriptionQueryResult
updates
in interface SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>
public boolean cancel()
Registration
cancel
in interface Registration
true
if this handler is successfully unregistered, false
if this handler
was not currently registered.Copyright © 2010–2018. All rights reserved.