private CommandOperationHelper.CommandTransformer<BsonDocument,MapReduceAsyncBatchCursor<T>> |
MapReduceWithInlineResultsOperation.asyncTransformer(AsyncConnection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,AsyncBatchCursor<T>> |
GroupOperation.asyncTransformer(AsyncConnection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,java.util.List<AsyncBatchCursor<T>>> |
ParallelCollectionScanOperation.asyncTransformer(AsyncConnectionSource source,
AsyncConnection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,AsyncBatchCursor<T>> |
ListIndexesOperation.asyncTransformer(AsyncConnectionSource source,
AsyncConnection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,AsyncBatchCursor<T>> |
ListDatabasesOperation.asyncTransformer(AsyncConnectionSource source,
AsyncConnection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,AsyncBatchCursor<T>> |
ListCollectionsOperation.asyncTransformer(AsyncConnectionSource source,
AsyncConnection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,AsyncBatchCursor<T>> |
FindOperation.asyncTransformer(AsyncConnectionSource source,
AsyncConnection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,AsyncBatchCursor<T>> |
AggregateOperation.asyncTransformer(AsyncConnectionSource source,
AsyncConnection connection) |
void |
OperationHelper.AsyncCallableWithConnectionAndSource.call(AsyncConnectionSource source,
AsyncConnection connection,
java.lang.Throwable t) |
void |
OperationHelper.AsyncCallableWithConnection.call(AsyncConnection connection,
java.lang.Throwable t) |
(package private) static void |
OperationHelper.checkBypassDocumentValidationIsSupported(AsyncConnection connection,
java.lang.Boolean bypassDocumentValidation,
WriteConcern writeConcern,
OperationHelper.AsyncCallableWithConnection callable) |
(package private) static <T> AsyncBatchCursor<T> |
OperationHelper.cursorDocumentToAsyncBatchCursor(BsonDocument cursorDocument,
Decoder<T> decoder,
AsyncConnectionSource source,
AsyncConnection connection,
int batchSize) |
(package private) void |
MixedBulkWriteOperation.Run.executeAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
protected void |
UpdateOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
protected void |
InsertOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
protected void |
DeleteOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
protected abstract void |
BaseWriteOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback)
Asynchronously executes the write command protocol.
|
protected void |
UpdateOperation.executeProtocolAsync(AsyncConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
protected void |
InsertOperation.executeProtocolAsync(AsyncConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
protected void |
DeleteOperation.executeProtocolAsync(AsyncConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
protected abstract void |
BaseWriteOperation.executeProtocolAsync(AsyncConnection connection,
SingleResultCallback<WriteConcernResult> callback)
Asynchronously executes the write protocol
|
private void |
MixedBulkWriteOperation.executeRunsAsync(java.util.Iterator<MixedBulkWriteOperation.Run> runs,
AsyncConnection connection,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
SingleResultCallback<BulkWriteResult> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<BsonDocument> decoder,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
AsyncConnection connection,
SingleResultCallback<BsonDocument> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<BsonDocument> decoder,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<BsonDocument> decoder,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
private static <D,T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
AsyncConnection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SingleResultCallback<T> callback) |
private static <D,T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
AsyncConnection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SingleResultCallback<T> callback) |
(package private) MixedBulkWriteOperation.Run.AsyncRunExecutor |
MixedBulkWriteOperation.Run.getDeletesRunExecutor(java.util.List<DeleteRequest> deleteRequests,
AsyncConnection connection) |
(package private) MixedBulkWriteOperation.Run.AsyncRunExecutor |
MixedBulkWriteOperation.Run.getInsertsRunExecutor(java.util.List<InsertRequest> insertRequests,
java.lang.Boolean bypassDocumentValidation,
AsyncConnection connection) |
private void |
AsyncQueryBatchCursor.getMore(AsyncConnection connection,
ServerCursor cursor,
SingleResultCallback<java.util.List<T>> callback) |
(package private) MixedBulkWriteOperation.Run.AsyncRunExecutor |
MixedBulkWriteOperation.Run.getUpdatesRunExecutor(java.util.List<UpdateRequest> updates,
java.lang.Boolean bypassDocumentValidation,
AsyncConnection connection) |
private void |
AsyncQueryBatchCursor.handleGetMoreQueryResult(AsyncConnection connection,
SingleResultCallback<java.util.List<T>> callback,
QueryResult<T> result) |
private void |
AsyncQueryBatchCursor.killCursor(AsyncConnection connection) |
private void |
AsyncQueryBatchCursor.killCursorAsynchronouslyAndReleaseConnectionAndSource(AsyncConnection connection,
ServerCursor localCursor) |
(package private) static <T> SingleResultCallback<T> |
OperationHelper.releasingCallback(SingleResultCallback<T> wrapped,
AsyncConnection connection) |
(package private) static <T> SingleResultCallback<T> |
OperationHelper.releasingCallback(SingleResultCallback<T> wrapped,
AsyncConnectionSource source,
AsyncConnection connection) |
(package private) static <T> SingleResultCallback<T> |
OperationHelper.releasingCallback(SingleResultCallback<T> wrapped,
AsyncReadBinding readBinding,
AsyncConnectionSource source,
AsyncConnection connection) |
(package private) static void |
OperationHelper.validateCollation(AsyncConnection connection,
Collation collation,
OperationHelper.AsyncCallableWithConnection callable) |
(package private) static void |
OperationHelper.validateCollation(AsyncConnectionSource source,
AsyncConnection connection,
Collation collation,
OperationHelper.AsyncCallableWithConnectionAndSource callable) |
(package private) static void |
OperationHelper.validateCollationAndWriteConcern(AsyncConnection connection,
Collation collation,
WriteConcern writeConcern,
OperationHelper.AsyncCallableWithConnection callable) |
(package private) static void |
OperationHelper.validateIndexRequestCollations(AsyncConnection connection,
java.util.List<IndexRequest> requests,
OperationHelper.AsyncCallableWithConnection callable) |
(package private) static void |
OperationHelper.validateReadConcern(AsyncConnection connection,
ReadConcern readConcern,
OperationHelper.AsyncCallableWithConnection callable) |
(package private) static void |
OperationHelper.validateReadConcern(AsyncConnectionSource source,
AsyncConnection connection,
ReadConcern readConcern,
OperationHelper.AsyncCallableWithConnectionAndSource callable) |
(package private) static void |
OperationHelper.validateReadConcernAndCollation(AsyncConnection connection,
ReadConcern readConcern,
Collation collation,
OperationHelper.AsyncCallableWithConnection callable) |
(package private) static void |
OperationHelper.validateReadConcernAndCollation(AsyncConnectionSource source,
AsyncConnection connection,
ReadConcern readConcern,
Collation collation,
OperationHelper.AsyncCallableWithConnectionAndSource callable) |
(package private) static void |
OperationHelper.validateWriteRequestCollations(AsyncConnection connection,
java.util.List<? extends WriteRequest> requests,
WriteConcern writeConcern,
OperationHelper.AsyncCallableWithConnection callable) |
(package private) static void |
OperationHelper.validateWriteRequests(AsyncConnection connection,
java.lang.Boolean bypassDocumentValidation,
java.util.List<? extends WriteRequest> requests,
WriteConcern writeConcern,
OperationHelper.AsyncCallableWithConnection callable) |