test_class.declarator: resultSet
test_class.modifier: private
test_class.original_string: private ResultSet resultSet;
test_class.type: ResultSet
test_class.var_name: resultSet
test_class.file: gremlin-driver/src/test/java/org/apache/tinkerpop/gremlin/driver/ResultSetTest.java
test_class.identifier: ResultSetTest
test_class.superclass: extends AbstractResultQueueTest
test_case.body: @Test
      public void shouldHaveAllItemsAvailableOnReadCompleteWhileLoading() throws Exception {
          assertThat(resultSet.allItemsAvailable(), is(false));
  
          final AtomicBoolean atLeastOnce = new AtomicBoolean(false);
          addToQueue(1000, 1, true, true);
          while (!readCompleted.isDone()) {
              atLeastOnce.set(true);
              if (!atLeastOnce.get())
                  assertThat(resultSet.allItemsAvailable(), is(false));
          }
  
          assertThat(atLeastOnce.get(), is(true));
          assertThat(resultSet.allItemsAvailable(), is(true));
      }
test_case.class_method_signature: ResultSetTest.shouldHaveAllItemsAvailableOnReadCompleteWhileLoading()
test_case.full_signature: @Test public void shouldHaveAllItemsAvailableOnReadCompleteWhileLoading()
test_case.identifier: shouldHaveAllItemsAvailableOnReadCompleteWhileLoading
test_case.invocations: assertThat allItemsAvailable is addToQueue isDone set get assertThat allItemsAvailable is assertThat get is assertThat allItemsAvailable is
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void shouldHaveAllItemsAvailableOnReadCompleteWhileLoading()
focal_class.declarator: resultQueue
focal_class.modifier: private final
focal_class.original_string: private final ResultQueue resultQueue;
focal_class.type: ResultQueue
focal_class.var_name: resultQueue
focal_class.declarator: executor
focal_class.modifier: private final
focal_class.original_string: private final ExecutorService executor;
focal_class.type: ExecutorService
focal_class.var_name: executor
focal_class.declarator: readCompleted
focal_class.modifier: private final
focal_class.original_string: private final CompletableFuture<Void> readCompleted;
focal_class.type: CompletableFuture<Void>
focal_class.var_name: readCompleted
focal_class.file: gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/ResultSet.java
focal_class.identifier: ResultSet
focal_class.interfaces: implements Iterable<Result>
focal_class.class_method_signature: ResultSet.ResultSet(final ResultQueue resultQueue, final ExecutorService executor,
                       final CompletableFuture<Void> readCompleted)
focal_class.full_signature: public  ResultSet(final ResultQueue resultQueue, final ExecutorService executor,
                       final CompletableFuture<Void> readCompleted)
focal_class.identifier: ResultSet
focal_class.modifiers: public
focal_class.parameters: (final ResultQueue resultQueue, final ExecutorService executor,
                       final CompletableFuture<Void> readCompleted)
focal_class.signature:  ResultSet(final ResultQueue resultQueue, final ExecutorService executor,
                       final CompletableFuture<Void> readCompleted)
focal_class.class_method_signature: ResultSet.allItemsAvailable()
focal_class.full_signature: public boolean allItemsAvailable()
focal_class.identifier: allItemsAvailable
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean allItemsAvailable()
focal_class.class_method_signature: ResultSet.getAvailableItemCount()
focal_class.full_signature: public int getAvailableItemCount()
focal_class.identifier: getAvailableItemCount
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int getAvailableItemCount()
focal_class.class_method_signature: ResultSet.one()
focal_class.full_signature: public Result one()
focal_class.identifier: one
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Result
focal_class.signature: Result one()
focal_class.class_method_signature: ResultSet.some(final int items)
focal_class.full_signature: public CompletableFuture<List<Result>> some(final int items)
focal_class.identifier: some
focal_class.modifiers: public
focal_class.parameters: (final int items)
focal_class.return: CompletableFuture<List<Result>>
focal_class.signature: CompletableFuture<List<Result>> some(final int items)
focal_class.class_method_signature: ResultSet.all()
focal_class.full_signature: public CompletableFuture<List<Result>> all()
focal_class.identifier: all
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: CompletableFuture<List<Result>>
focal_class.signature: CompletableFuture<List<Result>> all()
focal_class.class_method_signature: ResultSet.stream()
focal_class.full_signature: public Stream<Result> stream()
focal_class.identifier: stream
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Stream<Result>
focal_class.signature: Stream<Result> stream()
focal_class.class_method_signature: ResultSet.iterator()
focal_class.full_signature: @Override public Iterator<Result> iterator()
focal_class.identifier: iterator
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Iterator<Result>
focal_class.signature: Iterator<Result> iterator()
focal_method.body: public boolean allItemsAvailable() {
          return readCompleted.isDone();
      }
focal_method.class_method_signature: ResultSet.allItemsAvailable()
focal_method.full_signature: public boolean allItemsAvailable()
focal_method.identifier: allItemsAvailable
focal_method.invocations: isDone
focal_method.modifiers: public
focal_method.parameters: ()
focal_method.return: boolean
focal_method.signature: boolean allItemsAvailable()