Package com.atlassian.jira.search.index.bulk

Class BulkIndexResult.AsyncAccumulator

java.lang.Object

com.atlassian.jira.search.index.bulk.BulkIndexResult.AsyncAccumulator

Enclosing class:

BulkIndexResult

public static class BulkIndexResult.AsyncAccumulator
extends Object

Constructor Summary

Constructors

Constructor	Description
AsyncAccumulator()

Method Summary

Modifier and Type	Method	Description
BulkIndexResult.AsyncAccumulator	add(CompletableFuture<BulkIndexResult> future)	Add a CompletableFuture to the accumulator
BulkIndexResult.Accumulator	await()	Wait for all futures to complete and return an Accumulator with all results.

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncAccumulator

public AsyncAccumulator()

Method Details

add

public BulkIndexResult.AsyncAccumulator add(CompletableFuture<BulkIndexResult> future)

Add a CompletableFuture to the accumulator

Parameters:

future - the CompletableFuture to add

Returns:

this accumulator for method chaining

await

public BulkIndexResult.Accumulator await()

Wait for all futures to complete and return an Accumulator with all results. If an exception occurs in one of the threads, they will be tracked in the BulkIndexResult.Accumulator

Returns:

an Accumulator containing all the results from the completed futures