private abstract class MixedBulkWriteOperation.Run.AsyncRunExecutor extends MixedBulkWriteOperation.Run.BaseRunExecutor
Modifier and Type | Field and Description |
---|---|
private AsyncConnection |
connection |
Constructor and Description |
---|
AsyncRunExecutor(AsyncConnection connection) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
executeAsync(SingleResultCallback<BulkWriteResult> callback) |
private void |
executeRunWritesAsync(int numberOfRuns,
int currentPosition,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
SingleResultCallback<BulkWriteResult> callback) |
(package private) abstract void |
executeWriteCommandProtocolAsync(SingleResultCallback<BulkWriteResult> callback) |
(package private) abstract void |
executeWriteProtocolAsync(int index,
SingleResultCallback<WriteConcernResult> callback) |
getBulkWriteError, getCount, getResult, getResult, getResult, getType, getUpsertedItems, getUpsertedItems, getWriteConcernError
private final AsyncConnection connection
AsyncRunExecutor(AsyncConnection connection)
abstract void executeWriteProtocolAsync(int index, SingleResultCallback<WriteConcernResult> callback)
abstract void executeWriteCommandProtocolAsync(SingleResultCallback<BulkWriteResult> callback)
void executeAsync(SingleResultCallback<BulkWriteResult> callback)
private void executeRunWritesAsync(int numberOfRuns, int currentPosition, BulkWriteBatchCombiner bulkWriteBatchCombiner, SingleResultCallback<BulkWriteResult> callback)