File tree Expand file tree Collapse file tree 1 file changed +0
-7
lines changed
gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver Expand file tree Collapse file tree 1 file changed +0
-7
lines changed Original file line number Diff line number Diff line change @@ -42,8 +42,6 @@ public final class ResultQueue {
4242
4343 private final LinkedBlockingQueue <Result > resultLinkedBlockingQueue ;
4444
45- private final Object aggregatedResult = null ;
46-
4745 private final AtomicReference <Throwable > error = new AtomicReference <>();
4846
4947 private final CompletableFuture <Void > readComplete ;
@@ -94,11 +92,6 @@ void drainTo(final Collection<Result> collection) {
9492 }
9593
9694 public void markComplete () {
97- // if there was some aggregation performed in the queue then the full object is hanging out waiting to be
98- // added to the ResultSet
99- if (aggregatedResult != null )
100- add (new Result (aggregatedResult ));
101-
10295 this .readComplete .complete (null );
10396
10497 this .drainAllWaiting ();
You can’t perform that action at this time.
0 commit comments