I
- a generic specifying the type of the initial result of the SubscriptionQueryResult
U
- a generic specifying the type of the subsequent updates of the SubscriptionQueryResult
@Deprecated public class DisposableResult<I,U> extends Object implements SubscriptionQueryResult<I,U>
SubscriptionQueryResult
which adds the cancel()
operation.Constructor and Description |
---|
DisposableResult(SubscriptionQueryResult<I,U> delegate,
Registration registration)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
cancel()
Deprecated.
Cancels this Registration.
|
reactor.core.publisher.Mono<I> |
initialResult()
Deprecated.
Subscribing to this mono will trigger invocation of query handler.
|
reactor.core.publisher.Flux<U> |
updates()
Deprecated.
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)
delegate
- a SubscriptionQueryResult
which will be wrappedregistration
- a Registration
paired with the delegate
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 deregistered, false
if this handler
was not currently registered.Copyright © 2010–2023. All rights reserved.