the returned completablefuture completes when the number of items specified are available . thenumber returned will be equal to or less than that number . they will only be less if the stream is completed and there are less than that number specified available . concode_field_sep ResultQueue resultQueue concode_elem_sep ExecutorService executor concode_elem_sep CompletableFuture<Void> readCompleted concode_field_sep CompletableFuture<List<Result>> all concode_elem_sep Iterator<Result> iterator concode_elem_sep Stream<Result> stream concode_elem_sep boolean allItemsAvailable concode_elem_sep Result one concode_elem_sep int getAvailableItemCount
CompletableFuture < List < Result >> function ( final int arg0 ) { return resultQueue . await ( arg0 ) ; }