ResultQueue (Apache TinkerPop 4.0.0-beta.1 API)

java.lang.Object
- org.apache.tinkerpop.gremlin.driver.ResultQueue

```
public final class ResultQueue
extends Object
```
A queue of incoming Result objects. The queue is updated by the GremlinResponseHandler until a response terminator is identified.

Author:

Stephen Mallette (http://stephen.genoprime.com)

Constructor Summary

Constructors
Constructor Description

ResultQueue(LinkedBlockingQueue<Result> resultLinkedBlockingQueue, CompletableFuture<Void> readComplete)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`add(Result result)`	Adds a `Result` to the queue which will be later read by the `ResultSet`.
`CompletableFuture<List<Result>>`	`await(int items)`
`boolean`	`isComplete()`
`boolean`	`isEmpty()`
`void`	`markComplete()`
`void`	`markError(Throwable throwable)`
`int`	`size()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ResultQueue

public ResultQueue(LinkedBlockingQueue<Result> resultLinkedBlockingQueue,
                   CompletableFuture<Void> readComplete)

Method Detail

add
```
public void add(Result result)
```
Adds a Result to the queue which will be later read by the ResultSet.

Parameters:

result - a return value from the Traversal or script submitted for execution

await

public CompletableFuture<List<Result>> await(int items)

size
```
public int size()
```

isEmpty
```
public boolean isEmpty()
```

isComplete
```
public boolean isComplete()
```

markComplete
```
public void markComplete()
```

markError

public void markError(Throwable throwable)