org.axonframework.axonserver.connector.event.axon

Class QueryResultBuffer

java.lang.Object

org.axonframework.axonserver.connector.event.axon.QueryResultBuffer

All Implemented Interfaces:

AutoCloseable, Iterator<QueryResult>, QueryResultStream

public class QueryResultBuffer
extends Object
implements QueryResultStream

Client-side buffer of messages received from the server. Once consumed from this buffer, the client is notified of a permit being consumed, potentially triggering a permit refresh, if flow control is enabled.

This class is intended for internal use. Be cautious.

Since:

4.0

Author:

Marc Gathier

Constructor Summary

Constructors

Constructor and Description
QueryResultBuffer() Constructs a QueryResultBuffer

Method Summary

Modifier and Type	Method and Description
void	close()
void	fail(EventStoreException exception)
boolean	hasNext(int timeout, TimeUnit timeUnit) Validates whether there is a following entry in this stream to consume.
QueryResult	next() Returns the following QueryResult from this stream.
void	push(io.axoniq.axonserver.grpc.event.QueryEventsResponse eventWithToken)
void	registerCloseListener(Consumer<QueryResultBuffer> closeCallback)
void	registerConsumeListener(Consumer<Integer> consumeListener)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.axonserver.connector.event.axon.QueryResultStream

hasNext

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

QueryResultBuffer

public QueryResultBuffer()

Constructs a QueryResultBuffer

Method Detail

hasNext

public boolean hasNext(int timeout,
                       TimeUnit timeUnit)

Description copied from interface: QueryResultStream

Validates whether there is a following entry in this stream to consume. Uses the given timeout with the given unit to wait to respond

Specified by:

hasNext in interface QueryResultStream

Returns:

true if there is another entry, false if there isn't for at the given duration

next

public QueryResult next()

Description copied from interface: QueryResultStream

Returns the following QueryResult from this stream. Might return null if nothing is present

Specified by:

next in interface Iterator<QueryResult>

Specified by:

next in interface QueryResultStream

Returns:

the following QueryResult from this stream

close

public void close()

Specified by:

close in interface AutoCloseable

registerCloseListener

public void registerCloseListener(Consumer<QueryResultBuffer> closeCallback)

registerConsumeListener

public void registerConsumeListener(Consumer<Integer> consumeListener)

push

public void push(io.axoniq.axonserver.grpc.event.QueryEventsResponse eventWithToken)

fail

public void fail(EventStoreException exception)