public class QueryResultBuffer extends Object implements QueryResultStream
This class is intended for internal use. Be cautious.
Constructor and Description |
---|
QueryResultBuffer() |
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
hasNext
forEachRemaining, remove
public boolean hasNext(int timeout, TimeUnit timeUnit)
hasNext
in interface QueryResultStream
public QueryResult next()
next
in interface Iterator<QueryResult>
next
in interface QueryResultStream
public void close()
close
in interface AutoCloseable
public void registerCloseListener(Consumer<QueryResultBuffer> closeCallback)
public void push(QueryEventsResponse eventWithToken)
public void fail(EventStoreException exception)
Copyright © 2010–2018. All rights reserved.