org.axonframework.axonserver.connector.query.subscription

Class AxonServerSubscriptionQueryResult

java.lang.Object

org.axonframework.axonserver.connector.query.subscription.AxonServerSubscriptionQueryResult

All Implemented Interfaces:

io.grpc.stub.StreamObserver<SubscriptionQueryResponse>, Supplier<SubscriptionQueryResult<QueryResponse,QueryUpdate>>

public class AxonServerSubscriptionQueryResult
extends Object
implements Supplier<SubscriptionQueryResult<QueryResponse,QueryUpdate>>, io.grpc.stub.StreamObserver<SubscriptionQueryResponse>

SubscriptionQueryResult that emits initial response and update when subscription query response message is received.

Since:

4.0

Author:

Sara Pellegrini

Constructor Summary

Constructors

Constructor and Description
AxonServerSubscriptionQueryResult(SubscriptionQuery query, Function<io.grpc.stub.StreamObserver<SubscriptionQueryResponse>,io.grpc.stub.StreamObserver<SubscriptionQueryRequest>> openStreamFn, AxonServerConfiguration configuration, SubscriptionQueryBackpressure backPressure, int bufferSize, Runnable onDispose)

Method Summary

Modifier and Type	Method and Description
SubscriptionQueryResult<QueryResponse,QueryUpdate>	get()
void	onCompleted()
void	onError(Throwable t)
void	onNext(SubscriptionQueryResponse response)

Methods inherited from class java.lang.Object

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

Constructor Detail

AxonServerSubscriptionQueryResult

public AxonServerSubscriptionQueryResult(SubscriptionQuery query,
                                         Function<io.grpc.stub.StreamObserver<SubscriptionQueryResponse>,io.grpc.stub.StreamObserver<SubscriptionQueryRequest>> openStreamFn,
                                         AxonServerConfiguration configuration,
                                         SubscriptionQueryBackpressure backPressure,
                                         int bufferSize,
                                         Runnable onDispose)

Method Detail

onNext

public void onNext(SubscriptionQueryResponse response)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<SubscriptionQueryResponse>

onError

public void onError(Throwable t)

Specified by:

onError in interface io.grpc.stub.StreamObserver<SubscriptionQueryResponse>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<SubscriptionQueryResponse>

get

public SubscriptionQueryResult<QueryResponse,QueryUpdate> get()

Specified by:

get in interface Supplier<SubscriptionQueryResult<QueryResponse,QueryUpdate>>