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, org.axonframework.common.Registration, org.axonframework.queryhandling.SubscriptionQueryResult<I,U>
@Deprecated public class DisposableResult<I,U> extends Object implements org.axonframework.queryhandling.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(org.axonframework.queryhandling.SubscriptionQueryResult<I,U> delegate, org.axonframework.common.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.
     
    reactor.core.publisher.Mono<I>
    initialResult()
    Deprecated.
     
    reactor.core.publisher.Flux<U>
    updates()
    Deprecated.
     

    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(org.axonframework.queryhandling.SubscriptionQueryResult<I,U> delegate, org.axonframework.common.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.
      Specified by:
      initialResult in interface org.axonframework.queryhandling.SubscriptionQueryResult<I,U>

    • updates

      public reactor.core.publisher.Flux<U> updates()
      Deprecated.
      Specified by:
      updates in interface org.axonframework.queryhandling.SubscriptionQueryResult<I,U>

    • cancel

      public boolean cancel()
      Deprecated.
      Specified by:
      cancel in interface org.axonframework.common.Registration