Package | Description |
---|---|
com.mongodb.async.client |
This packages contains classes for the new async client
|
com.mongodb.async.client.gridfs |
Contains the classes for supporting MongoDB's specification for storing very large files, GridFS.
|
com.mongodb.operation |
The core of the MongoDB driver works via operations, using the command pattern.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
MappingAsyncBatchCursor<T,U> |
Modifier and Type | Field and Description |
---|---|
private AsyncBatchCursor<TResult> |
MongoIterableSubscription.batchCursor |
private AsyncBatchCursor<T> |
MappingAsyncBatchCursor.batchCursor |
Modifier and Type | Method and Description |
---|---|
private void |
MongoIterableImpl.loopCursor(AsyncBatchCursor<TResult> batchCursor,
Block<? super TResult> block,
SingleResultCallback<java.lang.Void> callback) |
Modifier and Type | Method and Description |
---|---|
void |
MongoIterableImpl.batchCursor(SingleResultCallback<AsyncBatchCursor<TResult>> callback) |
void |
MongoIterable.batchCursor(SingleResultCallback<AsyncBatchCursor<TResult>> callback)
Provide the underlying
AsyncBatchCursor allowing fine grained control of the cursor. |
void |
MappingIterable.batchCursor(SingleResultCallback<AsyncBatchCursor<V>> callback) |
void |
AggregateToCollectionThenFindOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
MapReduceIterableImpl.WrappedMapReduceReadOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<TResult>> callback) |
Constructor and Description |
---|
MappingAsyncBatchCursor(AsyncBatchCursor<T> batchCursor,
Function<T,U> mapper) |
Modifier and Type | Field and Description |
---|---|
private AsyncBatchCursor<Document> |
GridFSDownloadStreamImpl.cursor |
Modifier and Type | Method and Description |
---|---|
void |
GridFSFindIterableImpl.batchCursor(SingleResultCallback<AsyncBatchCursor<GridFSFile>> callback) |
Modifier and Type | Interface and Description |
---|---|
interface |
MapReduceAsyncBatchCursor<T>
Represents the future results of a map-reduce operation as a cursor.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
AsyncChangeStreamBatchCursor<T> |
(package private) class |
AsyncQueryBatchCursor<T> |
(package private) class |
AsyncSingleBatchQueryCursor<T> |
private class |
ListCollectionsOperation.ProjectingAsyncBatchCursor |
(package private) class |
MapReduceInlineResultsAsyncCursor<T>
Cursor representation of the results of an inline map-reduce operation.
|
Modifier and Type | Field and Description |
---|---|
private AsyncBatchCursor<BsonDocument> |
ListCollectionsOperation.ProjectingAsyncBatchCursor.delegate |
private AsyncBatchCursor<RawBsonDocument> |
AsyncChangeStreamBatchCursor.wrapped |
Modifier and Type | Method and Description |
---|---|
(package private) static <T> AsyncBatchCursor<T> |
OperationHelper.createEmptyAsyncBatchCursor(MongoNamespace namespace,
ServerAddress serverAddress) |
(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) |
(package private) AsyncBatchCursor<RawBsonDocument> |
AsyncChangeStreamBatchCursor.getWrapped() |
Modifier and Type | Method and Description |
---|---|
void |
AsyncChangeStreamBatchCursor.AsyncBlock.apply(AsyncBatchCursor<RawBsonDocument> cursor,
SingleResultCallback<java.util.List<RawBsonDocument>> callback) |
void |
FindOperation.ExplainResultCallback.onResult(AsyncBatchCursor<BsonDocument> cursor,
java.lang.Throwable t) |
Constructor and Description |
---|
AsyncChangeStreamBatchCursor(ChangeStreamOperation<T> changeStreamOperation,
AsyncBatchCursor<RawBsonDocument> wrapped,
AsyncReadBinding binding) |
ProjectingAsyncBatchCursor(AsyncBatchCursor<BsonDocument> delegate) |