public class DisposableResult<I,U> extends Object implements SubscriptionQueryResult<I,U>
Constructor and Description |
---|
DisposableResult(SubscriptionQueryResult<I,U> delegate,
Registration registration) |
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 DisposableResult(SubscriptionQueryResult<I,U> delegate, Registration registration)
public 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 unregistered, false
if this handler
was not currently registered.Copyright © 2010–2018. All rights reserved.