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.

Author:

Marc Gathier

Constructor Summary

Constructors

Constructor and Description
QueryResultBuffer()

Method Summary

Modifier and Type	Method and Description
void	close()
void	fail(EventStoreException exception)
boolean	hasNext(int timeout, TimeUnit timeUnit)
QueryResult	next()
void	push(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()

Method Detail

hasNext

public boolean hasNext(int timeout,
                       TimeUnit timeUnit)

Specified by:

hasNext in interface QueryResultStream

next

public QueryResult next()

Specified by:

next in interface Iterator<QueryResult>

Specified by:

next in interface QueryResultStream

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(QueryEventsResponse eventWithToken)

fail

public void fail(EventStoreException exception)