com.mongodb.operation

Class MixedBulkWriteOperation.Run.AsyncRunExecutor

java.lang.Object

com.mongodb.operation.MixedBulkWriteOperation.Run.BaseRunExecutor

com.mongodb.operation.MixedBulkWriteOperation.Run.AsyncRunExecutor

Enclosing class:

MixedBulkWriteOperation.Run

private abstract class MixedBulkWriteOperation.Run.AsyncRunExecutor
extends MixedBulkWriteOperation.Run.BaseRunExecutor

Field Summary

Fields

Modifier and Type	Field and Description
private AsyncConnection	connection

Constructor Summary

Constructors

Constructor and Description
AsyncRunExecutor(AsyncConnection connection)

Method Summary

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)

Methods inherited from class com.mongodb.operation.MixedBulkWriteOperation.Run.BaseRunExecutor

getBulkWriteError, getCount, getResult, getResult, getResult, getType, getUpsertedItems, getUpsertedItems, getWriteConcernError

Methods inherited from class java.lang.Object

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

Field Detail

connection

private final AsyncConnection connection

Constructor Detail

AsyncRunExecutor

AsyncRunExecutor(AsyncConnection connection)

Method Detail

executeWriteProtocolAsync

abstract void executeWriteProtocolAsync(int index,
                                        SingleResultCallback<WriteConcernResult> callback)

executeWriteCommandProtocolAsync

abstract void executeWriteCommandProtocolAsync(SingleResultCallback<BulkWriteResult> callback)

executeAsync

void executeAsync(SingleResultCallback<BulkWriteResult> callback)

executeRunWritesAsync

private void executeRunWritesAsync(int numberOfRuns,
                                   int currentPosition,
                                   BulkWriteBatchCombiner bulkWriteBatchCombiner,
                                   SingleResultCallback<BulkWriteResult> callback)