co.paralleluniverse.fibers.mongodb

Class FiberMongoCollectionImpl

java.lang.Object

com.allanbank.mongodb.client.AbstractMongoOperations

com.allanbank.mongodb.client.AbstractAsyncMongoCollection

com.allanbank.mongodb.client.SynchronousMongoCollectionImpl

co.paralleluniverse.fibers.mongodb.FiberMongoCollectionImpl

All Implemented Interfaces:

AsyncMongoCollection, MongoCollection

public class FiberMongoCollectionImpl
extends SynchronousMongoCollectionImpl

Nested Class Summary

Nested classes/interfaces inherited from interface com.allanbank.mongodb.MongoCollection

MongoCollection.ValidateMode

Field Summary

Fields inherited from class com.allanbank.mongodb.client.AbstractMongoOperations

DELETE_SINGLE_DELETE_DEFAULT, EMPTY_INDEX_OPTIONS, ID_FIELD_NAME, INSERT_CONTINUE_ON_ERROR_DEFAULT, myClient, myDatabase, myName, UNIQUE_INDEX_OPTIONS, UPDATE_MULTIUPDATE_DEFAULT, UPDATE_UPSERT_DEFAULT

Fields inherited from interface com.allanbank.mongodb.MongoCollection

ALL, NONE

Constructor Summary

Constructors

Constructor and Description
FiberMongoCollectionImpl(Client client, MongoDatabase md, String string)

Method Summary

Methods

Modifier and Type	Method and Description
MongoIterator<Document>	aggregate(Aggregate.Builder command)
MongoIterator<Document>	aggregate(Aggregate command)
ListenableFuture<MongoIterator<Document>>	aggregateAsync(Aggregate.Builder command)
ListenableFuture<MongoIterator<Document>>	aggregateAsync(Aggregate command)
long	count()
long	count(Count.Builder query)
long	count(Count query)
long	count(DocumentAssignable query, ReadPreference readPreference)
long	count(ReadPreference readPreference)
ListenableFuture<Long>	countAsync()
ListenableFuture<Long>	countAsync(Count.Builder builder)
ListenableFuture<Long>	countAsync(Count query)
ListenableFuture<Long>	countAsync(DocumentAssignable query)
ListenableFuture<Long>	countAsync(DocumentAssignable query, ReadPreference readPreference)
ListenableFuture<Long>	countAsync(ReadPreference readPreference)
long	delete(DocumentAssignable query)
long	delete(DocumentAssignable query, boolean singleDelete)
long	delete(DocumentAssignable query, boolean singleDelete, Durability durability)
long	delete(DocumentAssignable query, Durability durability)
ListenableFuture<Long>	deleteAsync(DocumentAssignable query)
ListenableFuture<Long>	deleteAsync(DocumentAssignable query, boolean singleDelete)
ListenableFuture<Long>	deleteAsync(DocumentAssignable query, boolean singleDelete, Durability durability)
ListenableFuture<Long>	deleteAsync(DocumentAssignable query, Durability durability)
MongoIterator<Element>	distinct(Distinct.Builder command)
MongoIterator<Element>	distinct(Distinct command)
ListenableFuture<MongoIterator<Element>>	distinctAsync(Distinct.Builder command)
ListenableFuture<MongoIterator<Element>>	distinctAsync(Distinct command)
Document	explain(Aggregate.Builder query)
Document	explain(Aggregate query)
Document	explain(DocumentAssignable query)
Document	explain(Find.Builder query)
Document	explain(Find query)
ListenableFuture<Document>	explainAsync(Aggregate.Builder query)
ListenableFuture<Document>	explainAsync(Aggregate query)
ListenableFuture<Document>	explainAsync(Find.Builder query)
ListenableFuture<Document>	explainAsync(Find query)
MongoIterator<Document>	find(DocumentAssignable query)
MongoIterator<Document>	find(Find.Builder query)
MongoIterator<Document>	find(Find query)
Document	findAndModify(FindAndModify.Builder query)
Document	findAndModify(FindAndModify query)
ListenableFuture<Document>	findAndModifyAsync(FindAndModify.Builder query)
ListenableFuture<Document>	findAndModifyAsync(FindAndModify query)
ListenableFuture<MongoIterator<Document>>	findAsync(DocumentAssignable query)
ListenableFuture<MongoIterator<Document>>	findAsync(Find.Builder query)
ListenableFuture<MongoIterator<Document>>	findAsync(Find query)
Document	findOne(DocumentAssignable query)
Document	findOne(Find.Builder query)
Document	findOne(Find query)
ListenableFuture<Document>	findOneAsync(DocumentAssignable query)
ListenableFuture<Document>	findOneAsync(Find.Builder query)
ListenableFuture<Document>	findOneAsync(Find query)
MongoIterator<Element>	groupBy(GroupBy.Builder command)
MongoIterator<Element>	groupBy(GroupBy command)
ListenableFuture<MongoIterator<Element>>	groupByAsync(GroupBy.Builder command)
ListenableFuture<MongoIterator<Element>>	groupByAsync(GroupBy command)
int	insert(boolean continueOnError, DocumentAssignable... documents)
int	insert(boolean continueOnError, Durability durability, DocumentAssignable... documents)
int	insert(DocumentAssignable... documents)
int	insert(Durability durability, DocumentAssignable[] documents)
ListenableFuture<Integer>	insertAsync(boolean continueOnError, DocumentAssignable... documents)
ListenableFuture<Integer>	insertAsync(boolean continueOnError, Durability durability, DocumentAssignable... documents)
ListenableFuture<Integer>	insertAsync(DocumentAssignable... documents)
ListenableFuture<Integer>	insertAsync(Durability durability, DocumentAssignable... documents)
MongoIterator<Document>	mapReduce(MapReduce.Builder command)
MongoIterator<Document>	mapReduce(MapReduce command)
ListenableFuture<MongoIterator<Document>>	mapReduceAsync(MapReduce.Builder command)
ListenableFuture<MongoIterator<Document>>	mapReduceAsync(MapReduce command)
Collection<MongoIterator<Document>>	parallelScan(ParallelScan.Builder command)
Collection<MongoIterator<Document>>	parallelScan(ParallelScan command)
ListenableFuture<Collection<MongoIterator<Document>>>	parallelScanAsync(ParallelScan.Builder command)
ListenableFuture<Collection<MongoIterator<Document>>>	parallelScanAsync(ParallelScan command)
int	save(DocumentAssignable query)
int	save(DocumentAssignable query, Durability durability)
ListenableFuture<Integer>	saveAsync(DocumentAssignable query)
ListenableFuture<Integer>	saveAsync(DocumentAssignable query, Durability durability)
MongoIterator<TextResult>	textSearch(Text.Builder command) Deprecated.
MongoIterator<TextResult>	textSearch(Text command) Deprecated.
ListenableFuture<MongoIterator<TextResult>>	textSearchAsync(Text.Builder command) Deprecated.
ListenableFuture<MongoIterator<TextResult>>	textSearchAsync(Text command) Deprecated.
long	update(DocumentAssignable query, DocumentAssignable update)
long	update(DocumentAssignable query, DocumentAssignable update, boolean multiUpdate, boolean upsert)
long	update(DocumentAssignable query, DocumentAssignable update, boolean multiUpdate, boolean upsert, Durability durability)
long	update(DocumentAssignable query, DocumentAssignable update, Durability durability)
ListenableFuture<Long>	updateAsync(DocumentAssignable query, DocumentAssignable update)
ListenableFuture<Long>	updateAsync(DocumentAssignable query, DocumentAssignable update, boolean multiUpdate, boolean upsert)
ListenableFuture<Long>	updateAsync(DocumentAssignable query, DocumentAssignable update, boolean multiUpdate, boolean upsert, Durability durability)
ListenableFuture<Long>	updateAsync(DocumentAssignable query, DocumentAssignable update, Durability durability)
long	write(BatchedWrite.Builder query)
long	write(BatchedWrite query)
ListenableFuture<Long>	writeAsync(BatchedWrite.Builder builder)
ListenableFuture<Long>	writeAsync(BatchedWrite query)

Methods inherited from class com.allanbank.mongodb.client.SynchronousMongoCollectionImpl

addOptions, count, createIndex, createIndex, createIndex, createIndex, createIndex, determineIndexServerVersion, drop, dropIndex, dropIndex, exists, isCapped, isCreateIndexesSupported, startBatch, stats, updateOptions, validate

Methods inherited from class com.allanbank.mongodb.client.AbstractAsyncMongoCollection

aggregateAsync, aggregateAsync, aggregateAsync, countAsync, countAsync, countAsync, countAsync, countAsync, countAsync, countAsync, countAsync, countAsync, countAsync, countAsync, deleteAsync, deleteAsync, deleteAsync, deleteAsync, deleteAsync, deleteAsync, deleteAsync, distinctAsync, distinctAsync, distinctAsync, explainAsync, explainAsync, explainAsync, explainAsync, explainAsync, explainAsync, findAndModifyAsync, findAndModifyAsync, findAndModifyAsync, findAsync, findAsync, findAsync, findAsync, findAsync, findOneAsync, findOneAsync, findOneAsync, findOneAsync, findOneAsync, getLockType, groupByAsync, groupByAsync, groupByAsync, insertAsync, insertAsync, insertAsync, insertAsync, insertAsync, insertAsync, insertAsync, mapReduceAsync, mapReduceAsync, mapReduceAsync, parallelScanAsync, parallelScanAsync, parallelScanAsync, saveAsync, saveAsync, saveAsync, stream, stream, stream, stream, stream, stream, streamingFind, streamingFind, streamingFind, streamingFind, streamingFind, streamingFind, textSearchAsync, updateAsync, updateAsync, updateAsync, updateAsync, updateAsync, updateAsync, updateAsync, writeAsync, writeAsync, writeAsync

Methods inherited from class com.allanbank.mongodb.client.AbstractMongoOperations

aggregateAsync, asGetLastError, countAsync, createQuery, deleteAsync, distinctAsync, doInsertAsync, doWriteAsync, explainAsync, explainAsync, findAndModifyAsync, findAsync, findOneAsync, getDatabaseName, getDurability, getName, getReadPreference, groupByAsync, insertAsync, isWriteCommandsSupported, mapReduceAsync, parallelScanAsync, saveAsync, setDurability, setReadPreference, stream, stream, textSearchAsync, toCommand, updateAsync, updateReadPreference, useWriteCommand, writeAsync

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.allanbank.mongodb.MongoCollection

getDatabaseName, getDurability, getName, getReadPreference, setDurability, setReadPreference

Methods inherited from interface com.allanbank.mongodb.AsyncMongoCollection

aggregateAsync, aggregateAsync, aggregateAsync, aggregateAsync, countAsync, countAsync, countAsync, countAsync, countAsync, countAsync, countAsync, countAsync, countAsync, countAsync, countAsync, countAsync, deleteAsync, deleteAsync, deleteAsync, deleteAsync, deleteAsync, deleteAsync, deleteAsync, deleteAsync, distinctAsync, distinctAsync, distinctAsync, distinctAsync, explainAsync, explainAsync, explainAsync, explainAsync, explainAsync, explainAsync, explainAsync, explainAsync, findAndModifyAsync, findAndModifyAsync, findAndModifyAsync, findAndModifyAsync, findAsync, findAsync, findAsync, findAsync, findAsync, findAsync, findOneAsync, findOneAsync, findOneAsync, findOneAsync, findOneAsync, findOneAsync, groupByAsync, groupByAsync, groupByAsync, groupByAsync, insertAsync, insertAsync, insertAsync, insertAsync, insertAsync, insertAsync, insertAsync, insertAsync, mapReduceAsync, mapReduceAsync, mapReduceAsync, mapReduceAsync, parallelScanAsync, parallelScanAsync, parallelScanAsync, parallelScanAsync, saveAsync, saveAsync, saveAsync, saveAsync, stream, stream, stream, stream, stream, stream, stream, stream, streamingFind, streamingFind, streamingFind, streamingFind, streamingFind, streamingFind, textSearchAsync, textSearchAsync, updateAsync, updateAsync, updateAsync, updateAsync, updateAsync, updateAsync, updateAsync, updateAsync, writeAsync, writeAsync, writeAsync, writeAsync

Constructor Detail

FiberMongoCollectionImpl

public FiberMongoCollectionImpl(Client client,
                        MongoDatabase md,
                        String string)

Method Detail

aggregate

@Suspendable
public MongoIterator<Document> aggregate(Aggregate.Builder command)
                                  throws MongoDbException

Specified by:

aggregate in interface MongoCollection

Overrides:

aggregate in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

aggregate

@Suspendable
public MongoIterator<Document> aggregate(Aggregate command)
                                  throws MongoDbException

Specified by:

aggregate in interface MongoCollection

Overrides:

aggregate in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

count

@Suspendable
public long count()
           throws MongoDbException

Specified by:

count in interface MongoCollection

Overrides:

count in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

count

@Suspendable
public long count(Count query)
           throws MongoDbException

Specified by:

count in interface MongoCollection

Overrides:

count in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

count

@Suspendable
public long count(Count.Builder query)
           throws MongoDbException

Specified by:

count in interface MongoCollection

Overrides:

count in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

count

@Suspendable
public long count(DocumentAssignable query,
                     ReadPreference readPreference)
           throws MongoDbException

Specified by:

count in interface MongoCollection

Overrides:

count in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

count

@Suspendable
public long count(ReadPreference readPreference)
           throws MongoDbException

Specified by:

count in interface MongoCollection

Overrides:

count in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

delete

@Suspendable
public long delete(DocumentAssignable query)
            throws MongoDbException

Specified by:

delete in interface MongoCollection

Overrides:

delete in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

delete

@Suspendable
public long delete(DocumentAssignable query,
                      boolean singleDelete)
            throws MongoDbException

Specified by:

delete in interface MongoCollection

Overrides:

delete in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

delete

@Suspendable
public long delete(DocumentAssignable query,
                      boolean singleDelete,
                      Durability durability)
            throws MongoDbException

Specified by:

delete in interface MongoCollection

Overrides:

delete in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

delete

@Suspendable
public long delete(DocumentAssignable query,
                      Durability durability)
            throws MongoDbException

Specified by:

delete in interface MongoCollection

Overrides:

delete in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

distinct

@Suspendable
public MongoIterator<Element> distinct(Distinct.Builder command)
                                throws MongoDbException

Specified by:

distinct in interface MongoCollection

Overrides:

distinct in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

distinct

@Suspendable
public MongoIterator<Element> distinct(Distinct command)
                                throws MongoDbException

Specified by:

distinct in interface MongoCollection

Overrides:

distinct in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

explain

@Suspendable
public Document explain(Aggregate.Builder query)
                 throws MongoDbException

Specified by:

explain in interface MongoCollection

Overrides:

explain in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

explain

@Suspendable
public Document explain(Aggregate query)
                 throws MongoDbException

Specified by:

explain in interface MongoCollection

Overrides:

explain in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

explain

@Suspendable
public Document explain(DocumentAssignable query)
                 throws MongoDbException

Specified by:

explain in interface MongoCollection

Overrides:

explain in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

explain

@Suspendable
public Document explain(Find.Builder query)
                 throws MongoDbException

Specified by:

explain in interface MongoCollection

Overrides:

explain in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

explain

@Suspendable
public Document explain(Find query)
                 throws MongoDbException

Specified by:

explain in interface MongoCollection

Overrides:

explain in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

find

@Suspendable
public MongoIterator<Document> find(DocumentAssignable query)
                             throws MongoDbException

Specified by:

find in interface MongoCollection

Overrides:

find in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

findAndModify

@Suspendable
public Document findAndModify(FindAndModify.Builder query)
                       throws MongoDbException

Specified by:

findAndModify in interface MongoCollection

Overrides:

findAndModify in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

findAndModify

@Suspendable
public Document findAndModify(FindAndModify query)
                       throws MongoDbException

Specified by:

findAndModify in interface MongoCollection

Overrides:

findAndModify in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

find

@Suspendable
public MongoIterator<Document> find(Find.Builder query)
                             throws MongoDbException

Specified by:

find in interface MongoCollection

Overrides:

find in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

find

@Suspendable
public MongoIterator<Document> find(Find query)
                             throws MongoDbException

Specified by:

find in interface MongoCollection

Overrides:

find in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

findOne

@Suspendable
public Document findOne(DocumentAssignable query)
                 throws MongoDbException

Specified by:

findOne in interface MongoCollection

Overrides:

findOne in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

findOne

@Suspendable
public Document findOne(Find.Builder query)
                 throws MongoDbException

Specified by:

findOne in interface MongoCollection

Overrides:

findOne in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

findOne

@Suspendable
public Document findOne(Find query)
                 throws MongoDbException

Specified by:

findOne in interface MongoCollection

Overrides:

findOne in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

groupBy

@Suspendable
public MongoIterator<Element> groupBy(GroupBy.Builder command)
                               throws MongoDbException

Specified by:

groupBy in interface MongoCollection

Overrides:

groupBy in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

groupBy

@Suspendable
public MongoIterator<Element> groupBy(GroupBy command)
                               throws MongoDbException

Specified by:

groupBy in interface MongoCollection

Overrides:

groupBy in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

insert

@Suspendable
public int insert(DocumentAssignable... documents)
           throws MongoDbException

Specified by:

insert in interface MongoCollection

Overrides:

insert in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

insert

@Suspendable
public int insert(Durability durability,
                     DocumentAssignable[] documents)
           throws MongoDbException

Specified by:

insert in interface MongoCollection

Overrides:

insert in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

insert

@Suspendable
public int insert(boolean continueOnError,
                     DocumentAssignable... documents)
           throws MongoDbException

Specified by:

insert in interface MongoCollection

Overrides:

insert in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

insert

@Suspendable
public int insert(boolean continueOnError,
                     Durability durability,
                     DocumentAssignable... documents)
           throws MongoDbException

Specified by:

insert in interface MongoCollection

Overrides:

insert in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

mapReduce

@Suspendable
public MongoIterator<Document> mapReduce(MapReduce.Builder command)
                                  throws MongoDbException

Specified by:

mapReduce in interface MongoCollection

Overrides:

mapReduce in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

mapReduce

@Suspendable
public MongoIterator<Document> mapReduce(MapReduce command)
                                  throws MongoDbException

Specified by:

mapReduce in interface MongoCollection

Overrides:

mapReduce in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

parallelScan

@Suspendable
public Collection<MongoIterator<Document>> parallelScan(ParallelScan.Builder command)
                                                 throws MongoDbException

Specified by:

parallelScan in interface MongoCollection

Overrides:

parallelScan in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

parallelScan

@Suspendable
public Collection<MongoIterator<Document>> parallelScan(ParallelScan command)
                                                 throws MongoDbException

Specified by:

parallelScan in interface MongoCollection

Overrides:

parallelScan in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

save

@Suspendable
public int save(DocumentAssignable query)
         throws MongoDbException

Specified by:

save in interface MongoCollection

Overrides:

save in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

save

@Suspendable
public int save(DocumentAssignable query,
                   Durability durability)
         throws MongoDbException

Specified by:

save in interface MongoCollection

Overrides:

save in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

textSearch

@Suspendable
@Deprecated
public MongoIterator<TextResult> textSearch(Text.Builder command)
                                     throws MongoDbException

Deprecated.

Specified by:

textSearch in interface MongoCollection

Overrides:

textSearch in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

textSearch

@Suspendable
@Deprecated
public MongoIterator<TextResult> textSearch(Text command)
                                     throws MongoDbException

Deprecated.

Specified by:

textSearch in interface MongoCollection

Overrides:

textSearch in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

update

@Suspendable
public long update(DocumentAssignable query,
                      DocumentAssignable update)
            throws MongoDbException

Specified by:

update in interface MongoCollection

Overrides:

update in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

update

@Suspendable
public long update(DocumentAssignable query,
                      DocumentAssignable update,
                      boolean multiUpdate,
                      boolean upsert)
            throws MongoDbException

Specified by:

update in interface MongoCollection

Overrides:

update in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

update

@Suspendable
public long update(DocumentAssignable query,
                      DocumentAssignable update,
                      boolean multiUpdate,
                      boolean upsert,
                      Durability durability)
            throws MongoDbException

Specified by:

update in interface MongoCollection

Overrides:

update in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

update

@Suspendable
public long update(DocumentAssignable query,
                      DocumentAssignable update,
                      Durability durability)
            throws MongoDbException

Specified by:

update in interface MongoCollection

Overrides:

update in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

write

@Suspendable
public long write(BatchedWrite query)
           throws MongoDbException

Specified by:

write in interface MongoCollection

Overrides:

write in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

write

@Suspendable
public long write(BatchedWrite.Builder query)
           throws MongoDbException

Specified by:

write in interface MongoCollection

Overrides:

write in class SynchronousMongoCollectionImpl

Throws:

MongoDbException

aggregateAsync

public ListenableFuture<MongoIterator<Document>> aggregateAsync(Aggregate.Builder command)
                                                         throws MongoDbException

Specified by:

aggregateAsync in interface AsyncMongoCollection

Overrides:

aggregateAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

aggregateAsync

public ListenableFuture<MongoIterator<Document>> aggregateAsync(Aggregate command)
                                                         throws MongoDbException

Specified by:

aggregateAsync in interface AsyncMongoCollection

Overrides:

aggregateAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

countAsync

public ListenableFuture<Long> countAsync()
                                  throws MongoDbException

Specified by:

countAsync in interface AsyncMongoCollection

Overrides:

countAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

countAsync

public ListenableFuture<Long> countAsync(Count.Builder builder)
                                  throws MongoDbException

Specified by:

countAsync in interface AsyncMongoCollection

Overrides:

countAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

countAsync

public ListenableFuture<Long> countAsync(Count query)
                                  throws MongoDbException

Specified by:

countAsync in interface AsyncMongoCollection

Overrides:

countAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

countAsync

public ListenableFuture<Long> countAsync(DocumentAssignable query)
                                  throws MongoDbException

Specified by:

countAsync in interface AsyncMongoCollection

Overrides:

countAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

countAsync

public ListenableFuture<Long> countAsync(DocumentAssignable query,
                                ReadPreference readPreference)
                                  throws MongoDbException

Specified by:

countAsync in interface AsyncMongoCollection

Overrides:

countAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

countAsync

public ListenableFuture<Long> countAsync(ReadPreference readPreference)
                                  throws MongoDbException

Specified by:

countAsync in interface AsyncMongoCollection

Overrides:

countAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

deleteAsync

public ListenableFuture<Long> deleteAsync(DocumentAssignable query)
                                   throws MongoDbException

Specified by:

deleteAsync in interface AsyncMongoCollection

Overrides:

deleteAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

deleteAsync

public ListenableFuture<Long> deleteAsync(DocumentAssignable query,
                                 boolean singleDelete)
                                   throws MongoDbException

Specified by:

deleteAsync in interface AsyncMongoCollection

Overrides:

deleteAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

deleteAsync

public ListenableFuture<Long> deleteAsync(DocumentAssignable query,
                                 boolean singleDelete,
                                 Durability durability)
                                   throws MongoDbException

Specified by:

deleteAsync in interface AsyncMongoCollection

Overrides:

deleteAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

deleteAsync

public ListenableFuture<Long> deleteAsync(DocumentAssignable query,
                                 Durability durability)
                                   throws MongoDbException

Specified by:

deleteAsync in interface AsyncMongoCollection

Overrides:

deleteAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

distinctAsync

public ListenableFuture<MongoIterator<Element>> distinctAsync(Distinct.Builder command)
                                                       throws MongoDbException

Specified by:

distinctAsync in interface AsyncMongoCollection

Overrides:

distinctAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

distinctAsync

public ListenableFuture<MongoIterator<Element>> distinctAsync(Distinct command)
                                                       throws MongoDbException

Specified by:

distinctAsync in interface AsyncMongoCollection

Overrides:

distinctAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

explainAsync

public ListenableFuture<Document> explainAsync(Aggregate.Builder query)
                                        throws MongoDbException

Specified by:

explainAsync in interface AsyncMongoCollection

Overrides:

explainAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

explainAsync

public ListenableFuture<Document> explainAsync(Aggregate query)
                                        throws MongoDbException

Specified by:

explainAsync in interface AsyncMongoCollection

Overrides:

explainAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

explainAsync

public ListenableFuture<Document> explainAsync(Find.Builder query)
                                        throws MongoDbException

Specified by:

explainAsync in interface AsyncMongoCollection

Overrides:

explainAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

explainAsync

public ListenableFuture<Document> explainAsync(Find query)
                                        throws MongoDbException

Specified by:

explainAsync in interface AsyncMongoCollection

Overrides:

explainAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

findAsync

public ListenableFuture<MongoIterator<Document>> findAsync(DocumentAssignable query)
                                                    throws MongoDbException

Specified by:

findAsync in interface AsyncMongoCollection

Overrides:

findAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

findAsync

public ListenableFuture<MongoIterator<Document>> findAsync(Find.Builder query)
                                                    throws MongoDbException

Specified by:

findAsync in interface AsyncMongoCollection

Overrides:

findAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

findAsync

public ListenableFuture<MongoIterator<Document>> findAsync(Find query)
                                                    throws MongoDbException

Specified by:

findAsync in interface AsyncMongoCollection

Overrides:

findAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

findAndModifyAsync

public ListenableFuture<Document> findAndModifyAsync(FindAndModify query)
                                              throws MongoDbException

Specified by:

findAndModifyAsync in interface AsyncMongoCollection

Overrides:

findAndModifyAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

findAndModifyAsync

public ListenableFuture<Document> findAndModifyAsync(FindAndModify.Builder query)
                                              throws MongoDbException

Specified by:

findAndModifyAsync in interface AsyncMongoCollection

Overrides:

findAndModifyAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

findOneAsync

public ListenableFuture<Document> findOneAsync(DocumentAssignable query)
                                        throws MongoDbException

Specified by:

findOneAsync in interface AsyncMongoCollection

Overrides:

findOneAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

findOneAsync

public ListenableFuture<Document> findOneAsync(Find.Builder query)
                                        throws MongoDbException

Specified by:

findOneAsync in interface AsyncMongoCollection

Overrides:

findOneAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

findOneAsync

public ListenableFuture<Document> findOneAsync(Find query)
                                        throws MongoDbException

Specified by:

findOneAsync in interface AsyncMongoCollection

Overrides:

findOneAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

groupByAsync

public ListenableFuture<MongoIterator<Element>> groupByAsync(GroupBy.Builder command)
                                                      throws MongoDbException

Specified by:

groupByAsync in interface AsyncMongoCollection

Overrides:

groupByAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

groupByAsync

public ListenableFuture<MongoIterator<Element>> groupByAsync(GroupBy command)
                                                      throws MongoDbException

Specified by:

groupByAsync in interface AsyncMongoCollection

Overrides:

groupByAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

insertAsync

public ListenableFuture<Integer> insertAsync(DocumentAssignable... documents)
                                      throws MongoDbException

Specified by:

insertAsync in interface AsyncMongoCollection

Overrides:

insertAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

insertAsync

public ListenableFuture<Integer> insertAsync(Durability durability,
                                    DocumentAssignable... documents)
                                      throws MongoDbException

Specified by:

insertAsync in interface AsyncMongoCollection

Overrides:

insertAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

insertAsync

public ListenableFuture<Integer> insertAsync(boolean continueOnError,
                                    DocumentAssignable... documents)
                                      throws MongoDbException

Specified by:

insertAsync in interface AsyncMongoCollection

Overrides:

insertAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

insertAsync

public ListenableFuture<Integer> insertAsync(boolean continueOnError,
                                    Durability durability,
                                    DocumentAssignable... documents)
                                      throws MongoDbException

Specified by:

insertAsync in interface AsyncMongoCollection

Overrides:

insertAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

mapReduceAsync

public ListenableFuture<MongoIterator<Document>> mapReduceAsync(MapReduce.Builder command)
                                                         throws MongoDbException

Specified by:

mapReduceAsync in interface AsyncMongoCollection

Overrides:

mapReduceAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

mapReduceAsync

public ListenableFuture<MongoIterator<Document>> mapReduceAsync(MapReduce command)
                                                         throws MongoDbException

Specified by:

mapReduceAsync in interface AsyncMongoCollection

Overrides:

mapReduceAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

parallelScanAsync

public ListenableFuture<Collection<MongoIterator<Document>>> parallelScanAsync(ParallelScan.Builder command)
                                                                        throws MongoDbException

Specified by:

parallelScanAsync in interface AsyncMongoCollection

Overrides:

parallelScanAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

parallelScanAsync

public ListenableFuture<Collection<MongoIterator<Document>>> parallelScanAsync(ParallelScan command)
                                                                        throws MongoDbException

Specified by:

parallelScanAsync in interface AsyncMongoCollection

Overrides:

parallelScanAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

saveAsync

public ListenableFuture<Integer> saveAsync(DocumentAssignable query)
                                    throws MongoDbException

Specified by:

saveAsync in interface AsyncMongoCollection

Overrides:

saveAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

saveAsync

public ListenableFuture<Integer> saveAsync(DocumentAssignable query,
                                  Durability durability)
                                    throws MongoDbException

Specified by:

saveAsync in interface AsyncMongoCollection

Overrides:

saveAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

textSearchAsync

@Deprecated
public ListenableFuture<MongoIterator<TextResult>> textSearchAsync(Text.Builder command)
                                                            throws MongoDbException

Deprecated.

Specified by:

textSearchAsync in interface AsyncMongoCollection

Overrides:

textSearchAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

textSearchAsync

@Deprecated
public ListenableFuture<MongoIterator<TextResult>> textSearchAsync(Text command)
                                                            throws MongoDbException

Deprecated.

Specified by:

textSearchAsync in interface AsyncMongoCollection

Overrides:

textSearchAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

updateAsync

public ListenableFuture<Long> updateAsync(DocumentAssignable query,
                                 DocumentAssignable update)
                                   throws MongoDbException

Specified by:

updateAsync in interface AsyncMongoCollection

Overrides:

updateAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

updateAsync

public ListenableFuture<Long> updateAsync(DocumentAssignable query,
                                 DocumentAssignable update,
                                 boolean multiUpdate,
                                 boolean upsert)
                                   throws MongoDbException

Specified by:

updateAsync in interface AsyncMongoCollection

Overrides:

updateAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

updateAsync

public ListenableFuture<Long> updateAsync(DocumentAssignable query,
                                 DocumentAssignable update,
                                 boolean multiUpdate,
                                 boolean upsert,
                                 Durability durability)
                                   throws MongoDbException

Specified by:

updateAsync in interface AsyncMongoCollection

Overrides:

updateAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

updateAsync

public ListenableFuture<Long> updateAsync(DocumentAssignable query,
                                 DocumentAssignable update,
                                 Durability durability)
                                   throws MongoDbException

Specified by:

updateAsync in interface AsyncMongoCollection

Overrides:

updateAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

writeAsync

public ListenableFuture<Long> writeAsync(BatchedWrite.Builder builder)
                                  throws MongoDbException

Specified by:

writeAsync in interface AsyncMongoCollection

Overrides:

writeAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException

writeAsync

public ListenableFuture<Long> writeAsync(BatchedWrite query)
                                  throws MongoDbException

Specified by:

writeAsync in interface AsyncMongoCollection

Overrides:

writeAsync in class AbstractAsyncMongoCollection

Throws:

MongoDbException