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>

A 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 subscriptionQuery, Function<io.grpc.stub.StreamObserver<SubscriptionQueryResponse>,io.grpc.stub.StreamObserver<SubscriptionQueryRequest>> openStreamFn, AxonServerConfiguration configuration, SubscriptionQueryBackpressure backPressure, int bufferSize, Runnable onDispose) Instantiate a AxonServerSubscriptionQueryResult which will emit its initial response and the updates of the subscription query.

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 subscriptionQuery,
                                         Function<io.grpc.stub.StreamObserver<SubscriptionQueryResponse>,io.grpc.stub.StreamObserver<SubscriptionQueryRequest>> openStreamFn,
                                         AxonServerConfiguration configuration,
                                         SubscriptionQueryBackpressure backPressure,
                                         int bufferSize,
                                         Runnable onDispose)

Instantiate a AxonServerSubscriptionQueryResult which will emit its initial response and the updates of the subscription query.

Parameters:

subscriptionQuery - the SubscriptionQuery which is sent

openStreamFn - a Function used to open the stream results

configuration - a AxonServerConfiguration providing the specified flow control settings

backPressure - the used SubscriptionQueryBackpressure for the subsequent updates of the subscription query

bufferSize - an int specifying the buffer size of the updates

onDispose - a Runnable which will be Runnable.run() this subscription query has completed (exceptionally)

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>>