final class ListCollectionsIterableImpl<TResult> extends MongoIterableImpl<TResult> implements ListCollectionsIterable<TResult>
| Modifier and Type | Field and Description |
|---|---|
private CodecRegistry |
codecRegistry |
private java.lang.String |
databaseName |
private Bson |
filter |
private long |
maxTimeMS |
private java.lang.Class<TResult> |
resultClass |
| Constructor and Description |
|---|
ListCollectionsIterableImpl(ClientSession clientSession,
java.lang.String databaseName,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
AsyncOperationExecutor executor) |
| Modifier and Type | Method and Description |
|---|---|
(package private) AsyncReadOperation<AsyncBatchCursor<TResult>> |
asAsyncReadOperation() |
ListCollectionsIterable<TResult> |
batchSize(int batchSize)
Sets the number of documents to return per batch.
|
ListCollectionsIterable<TResult> |
filter(Bson filter)
Sets the query filter to apply to the query.
|
ListCollectionsIterable<TResult> |
maxTime(long maxTime,
java.util.concurrent.TimeUnit timeUnit)
Sets the maximum execution time on the server for this operation.
|
batchCursor, first, forEach, getBatchSize, getClientSession, getExecutor, getReadConcern, getReadPreference, into, map, toBsonDocumentOrNull, toBsonDocumentOrNullclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitbatchCursor, first, forEach, into, mapprivate final java.lang.String databaseName
private final java.lang.Class<TResult> resultClass
private final CodecRegistry codecRegistry
private Bson filter
private long maxTimeMS
ListCollectionsIterableImpl(ClientSession clientSession, java.lang.String databaseName, java.lang.Class<TResult> resultClass, CodecRegistry codecRegistry, ReadPreference readPreference, AsyncOperationExecutor executor)
public ListCollectionsIterable<TResult> filter(Bson filter)
ListCollectionsIterablefilter in interface ListCollectionsIterable<TResult>filter - the filter, which may be null.public ListCollectionsIterable<TResult> maxTime(long maxTime, java.util.concurrent.TimeUnit timeUnit)
ListCollectionsIterablemaxTime in interface ListCollectionsIterable<TResult>maxTime - the max timetimeUnit - the time unit, which may not be nullpublic ListCollectionsIterable<TResult> batchSize(int batchSize)
MongoIterablebatchSize in interface ListCollectionsIterable<TResult>batchSize in interface MongoIterable<TResult>batchSize in class MongoIterableImpl<TResult>batchSize - the batch sizeAsyncReadOperation<AsyncBatchCursor<TResult>> asAsyncReadOperation()
asAsyncReadOperation in class MongoIterableImpl<TResult>