private CommandOperationHelper.CommandTransformer<BsonDocument,AsyncBatchCursor<T>> |
ListDatabasesOperation.asyncTransformer(AsyncConnectionSource source,
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>> |
ListCollectionsOperation.asyncTransformer(AsyncConnectionSource source,
AsyncConnection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,AsyncBatchCursor<T>> |
AggregateOperation.asyncTransformer(AsyncConnectionSource source,
AsyncConnection connection) |
private CommandOperationHelper.CommandTransformer<BsonDocument,AsyncBatchCursor<T>> |
FindOperation.asyncTransformer(AsyncConnectionSource source,
AsyncConnection connection) |
void |
OperationHelper.AsyncCallableWithConnectionAndSource.call(AsyncConnectionSource source,
AsyncConnection connection,
java.lang.Throwable t) |
(package private) static <T> AsyncBatchCursor<T> |
OperationHelper.cursorDocumentToAsyncBatchCursor(BsonDocument cursorDocument,
Decoder<T> decoder,
AsyncConnectionSource source,
AsyncConnection connection,
int batchSize) |
private AsyncBatchCursor<T> |
ListIndexesOperation.emptyAsyncCursor(AsyncConnectionSource source) |
private AsyncBatchCursor<T> |
ListCollectionsOperation.emptyAsyncCursor(AsyncConnectionSource source) |
private void |
AsyncQueryBatchCursor.killCursorAsynchronouslyAndReleaseConnectionAndSource(AsyncConnection connection,
ServerCursor localCursor,
AsyncConnectionSource localConnectionSource) |
void |
OperationHelper.AsyncCallableWithConnectionCallback.onResult(AsyncConnectionSource source,
java.lang.Throwable t) |
void |
OperationHelper.AsyncCallableWithConnectionAndSourceCallback.onResult(AsyncConnectionSource source,
java.lang.Throwable t) |
void |
CommandOperationHelper.CommandProtocolExecutingCallback.onResult(AsyncConnectionSource source,
java.lang.Throwable t) |
(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(AsyncConnectionSource source,
AsyncConnection connection,
Collation collation,
OperationHelper.AsyncCallableWithConnectionAndSource callable) |
(package private) static void |
OperationHelper.validateReadConcern(AsyncConnectionSource source,
AsyncConnection connection,
ReadConcern readConcern,
OperationHelper.AsyncCallableWithConnectionAndSource callable) |
(package private) static void |
OperationHelper.validateReadConcernAndCollation(AsyncConnectionSource source,
AsyncConnection connection,
ReadConcern readConcern,
Collation collation,
OperationHelper.AsyncCallableWithConnectionAndSource callable) |
private static void |
OperationHelper.withConnectionSource(AsyncConnectionSource source,
OperationHelper.AsyncCallableWithConnection callable) |
private static void |
OperationHelper.withConnectionSource(AsyncConnectionSource source,
OperationHelper.AsyncCallableWithConnectionAndSource callable) |