ai.grakn.grpc

Class GrpcIterators

java.lang.Object

ai.grakn.grpc.GrpcIterators

public class GrpcIterators
extends Object

Contains a mutable map of iterators of GrpcGrakn.TxResponses for gRPC. These iterators are used for returning lazy, streaming responses such as for Graql query results.

Author:

Felix Chapman

Method Summary

Modifier and Type	Method and Description
GrpcIterator.IteratorId	add(Iterator<GrpcGrakn.TxResponse> iterator) Register a new iterator and return the ID of the iterator
static GrpcIterators	create()
Optional<GrpcGrakn.TxResponse>	next(GrpcIterator.IteratorId iteratorId) Return the next response from an iterator.
void	stop(GrpcIterator.IteratorId iteratorId) Stop an iterator

Methods inherited from class java.lang.Object

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

Method Detail

create

public static GrpcIterators create()

add

public GrpcIterator.IteratorId add(Iterator<GrpcGrakn.TxResponse> iterator)

Register a new iterator and return the ID of the iterator

next

public Optional<GrpcGrakn.TxResponse> next(GrpcIterator.IteratorId iteratorId)

Return the next response from an iterator. Will return a GrpcGrakn.Done response if the iterator is exhausted.

stop

public void stop(GrpcIterator.IteratorId iteratorId)

Stop an iterator