com.mongodb

Class MongoIterableImpl<TResult>

java.lang.Object

com.mongodb.MongoIterableImpl<TResult>

All Implemented Interfaces:

MongoIterable<TResult>, java.lang.Iterable<TResult>

Direct Known Subclasses:

AggregateIterableImpl, ChangeStreamIterableImpl, DistinctIterableImpl, FindIterableImpl, ListCollectionsIterableImpl, ListDatabasesIterableImpl, ListIndexesIterableImpl, MapReduceIterableImpl

abstract class MongoIterableImpl<TResult>
extends java.lang.Object
implements MongoIterable<TResult>

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.Integer	batchSize
private ClientSession	clientSession
private OperationExecutor	executor
private ReadConcern	readConcern
private ReadPreference	readPreference

Constructor Summary

Constructors

Constructor and Description
MongoIterableImpl(ClientSession clientSession, OperationExecutor executor, ReadConcern readConcern, ReadPreference readPreference)

Method Summary

Modifier and Type	Method and Description
(package private) abstract ReadOperation<BatchCursor<TResult>>	asReadOperation()
MongoIterable<TResult>	batchSize(int batchSize) Sets the number of documents to return per batch.
private BatchCursor<TResult>	execute()
TResult	first() Helper to return the first item in the iterator or null.
void	forEach(Block<? super TResult> block) Iterates over all documents in the view, applying the given block to each.
java.lang.Integer	getBatchSize()
(package private) ClientSession	getClientSession()
(package private) OperationExecutor	getExecutor()
(package private) ReadConcern	getReadConcern()
(package private) ReadPreference	getReadPreference()
<A extends java.util.Collection<? super TResult>> A	into(A target) Iterates over all the documents, adding each to the given target.
MongoCursor<TResult>	iterator()
<U> MongoIterable<U>	map(Function<TResult,U> mapper) Maps this iterable from the source document type to the target document type.
(package private) <T> BsonDocument	toBsonDocumentOrNull(Bson document, java.lang.Class<T> documentClass, CodecRegistry codecRegistry)
(package private) BsonDocument	toBsonDocumentOrNull(Bson document, CodecRegistry codecRegistry)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

clientSession

private final ClientSession clientSession

readConcern

private final ReadConcern readConcern

executor

private OperationExecutor executor

readPreference

private ReadPreference readPreference

batchSize

private java.lang.Integer batchSize

Constructor Detail

MongoIterableImpl

MongoIterableImpl(ClientSession clientSession,
                  OperationExecutor executor,
                  ReadConcern readConcern,
                  ReadPreference readPreference)

Method Detail

asReadOperation

abstract ReadOperation<BatchCursor<TResult>> asReadOperation()

getClientSession

ClientSession getClientSession()

getExecutor

OperationExecutor getExecutor()

getReadPreference

ReadPreference getReadPreference()

getReadConcern

ReadConcern getReadConcern()

getBatchSize

public java.lang.Integer getBatchSize()

batchSize

public MongoIterable<TResult> batchSize(int batchSize)

Description copied from interface: MongoIterable

Sets the number of documents to return per batch.

Specified by:

batchSize in interface MongoIterable<TResult>

Parameters:

batchSize - the batch size

Returns:

this

iterator

public MongoCursor<TResult> iterator()

Specified by:

iterator in interface MongoIterable<TResult>

Specified by:

iterator in interface java.lang.Iterable<TResult>

first

public TResult first()

Description copied from interface: MongoIterable

Helper to return the first item in the iterator or null.

Specified by:

first in interface MongoIterable<TResult>

Returns:

T the first item or null.

map

public <U> MongoIterable<U> map(Function<TResult,U> mapper)

Description copied from interface: MongoIterable

Maps this iterable from the source document type to the target document type.

Specified by:

map in interface MongoIterable<TResult>

Type Parameters:

U - the target document type

Parameters:

mapper - a function that maps from the source to the target document type

Returns:

an iterable which maps T to U

forEach

public void forEach(Block<? super TResult> block)

Description copied from interface: MongoIterable

Iterates over all documents in the view, applying the given block to each.

Similar to map but the function is fully encapsulated with no returned result.

Specified by:

forEach in interface MongoIterable<TResult>

Parameters:

block - the block to apply to each document of type T.

into

public <A extends java.util.Collection<? super TResult>> A into(A target)

Description copied from interface: MongoIterable

Iterates over all the documents, adding each to the given target.

Specified by:

into in interface MongoIterable<TResult>

Type Parameters:

A - the collection type

Parameters:

target - the collection to insert into

Returns:

the target

toBsonDocumentOrNull

BsonDocument toBsonDocumentOrNull(Bson document,
                                  CodecRegistry codecRegistry)

toBsonDocumentOrNull

<T> BsonDocument toBsonDocumentOrNull(Bson document,
                                      java.lang.Class<T> documentClass,
                                      CodecRegistry codecRegistry)

execute

private BatchCursor<TResult> execute()