org.axonframework.axonserver.connector.event.axon

Interface QueryResultStream

All Superinterfaces:

AutoCloseable, Iterator<QueryResult>

All Known Implementing Classes:

QueryResultBuffer

public interface QueryResultStream
extends Iterator<QueryResult>, AutoCloseable

Iterator to process the results of a query. Adds hasNext(timeout, TimeUnit timeUnit) operation to limit the time to wait for the next result.

Since:

4.0

Author:

Marc Gathier

Method Summary

Modifier and Type	Method and Description
default boolean	hasNext() Validates whether there is a following entry in this stream to consume.
boolean	hasNext(int timeout, TimeUnit unit) Validates whether there is a following entry in this stream to consume.
QueryResult	next() Returns the following QueryResult from this stream.

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

hasNext

default boolean hasNext()

Validates whether there is a following entry in this stream to consume. This method will wait for 1 second to return.

Specified by:

hasNext in interface Iterator<QueryResult>

Returns:

true if there is another entry, false if there isn't for at least 1 second

hasNext

boolean hasNext(int timeout,
                TimeUnit unit)

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

Returns:

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

next

QueryResult next()

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

Specified by:

next in interface Iterator<QueryResult>

Returns:

the following QueryResult from this stream