Package org.axonframework.axonserver.connector.query.subscription

Class DisposableResult<I,U>

java.lang.Object

org.axonframework.axonserver.connector.query.subscription.DisposableResult<I,U>

Type Parameters:

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

All Implemented Interfaces:

AutoCloseable, Registration, SubscriptionQueryResult<I,U>

@Deprecated
public class DisposableResult<I,U>
extends Object
implements SubscriptionQueryResult<I,U>

Deprecated.

in through use of the AxonServer java connector

A decorator of the SubscriptionQueryResult which adds the cancel() operation.

Since:

4.0

Author:

Sara Pellegrini

Field Summary

Fields inherited from interface org.axonframework.queryhandling.SubscriptionQueryResult

logger

Constructor Summary

Constructors

Constructor	Description
DisposableResult(SubscriptionQueryResult<I,U> delegate, Registration registration)	Deprecated. Instantiate a DisposableResult wrapping the delegate, opening up the capability to cancel() it.

Method Summary

Modifier and Type	Method	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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.axonframework.common.Registration

close

Methods inherited from interface org.axonframework.queryhandling.SubscriptionQueryResult

handle, handle

Constructor Details

DisposableResult

public DisposableResult(SubscriptionQueryResult<I,U> delegate,
 Registration registration)

Deprecated.

Instantiate a DisposableResult wrapping the delegate, opening up the capability to cancel() it.

Parameters:

delegate - a SubscriptionQueryResult which will be wrapped

registration - a Registration paired with the delegate

Method Details

initialResult

public reactor.core.publisher.Mono<I> initialResult()

Deprecated.

Description copied from interface: SubscriptionQueryResult

Subscribing to this mono will trigger invocation of query handler. The return value of that query handler will be passed to the mono, once it's ready.

Specified by:

initialResult in interface SubscriptionQueryResult<I,U>

Returns:

the mono representing the initial result

updates

public reactor.core.publisher.Flux<U> updates()

Deprecated.

Description copied from interface: SubscriptionQueryResult

When there is an update to the subscription query, it will be emitted to this flux.

Specified by:

updates in interface SubscriptionQueryResult<I,U>

Returns:

the flux representing the incremental updates

cancel

public boolean cancel()

Deprecated.

Description copied from interface: Registration

Cancels this Registration. If the Registration was already cancelled, no action is taken.

Specified by:

cancel in interface Registration

Returns:

true if this handler is successfully deregistered, false if this handler was not currently registered.