com.mongodb.async.client

Class MappingIterable<T,U>

java.lang.Object

com.mongodb.async.client.MappingIterable<T,U>

All Implemented Interfaces:

MongoIterable<U>

class MappingIterable<T,U>
extends java.lang.Object
implements MongoIterable<U>

Field Summary

Fields

Modifier and Type	Field and Description
private MongoIterable<T>	iterable
private Function<T,U>	mapper

Constructor Summary

Constructors

Constructor and Description
MappingIterable(MongoIterable<T> iterable, Function<T,U> mapper)

Method Summary

Modifier and Type	Method and Description
void	batchCursor(SingleResultCallback<AsyncBatchCursor<U>> callback) Provide the underlying AsyncBatchCursor allowing fine grained control of the cursor.
MongoIterable<U>	batchSize(int batchSize) Sets the number of documents to return per batch.
void	first(SingleResultCallback<U> callback) Helper to return the first item in the iterator or null.
void	forEach(Block<? super U> block, SingleResultCallback<java.lang.Void> callback) Iterates over all documents in the view, applying the given block to each, and completing the returned future after all documents have been iterated, or an exception has occurred.
<A extends java.util.Collection<? super U>> void	into(A target, SingleResultCallback<A> callback) Iterates over all the documents, adding each to the given target.
<V> MongoIterable<V>	map(Function<U,V> mapper) Maps this iterable from the source document type to the target document type.

Methods inherited from class java.lang.Object

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

Field Detail

iterable

private final MongoIterable<T> iterable

mapper

private final Function<T,U> mapper

Constructor Detail

MappingIterable

public MappingIterable(MongoIterable<T> iterable,
                       Function<T,U> mapper)

Method Detail

first

public void first(SingleResultCallback<U> callback)

Description copied from interface: MongoIterable

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

Specified by:

first in interface MongoIterable<U>

Parameters:

callback - a callback that is passed the first item or null.

forEach

public void forEach(Block<? super U> block,
                    SingleResultCallback<java.lang.Void> callback)

Description copied from interface: MongoIterable

Iterates over all documents in the view, applying the given block to each, and completing the returned future after all documents have been iterated, or an exception has occurred.

Specified by:

forEach in interface MongoIterable<U>

Parameters:

block - the block to apply to each document

callback - a callback that completed once the iteration has completed

into

public <A extends java.util.Collection<? super U>> void into(A target,
                                                             SingleResultCallback<A> callback)

Description copied from interface: MongoIterable

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

Specified by:

into in interface MongoIterable<U>

Type Parameters:

A - the collection type

Parameters:

target - the collection to insert into

callback - a callback that will be passed the target containing all documents

map

public <V> MongoIterable<V> map(Function<U,V> 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<U>

Type Parameters:

V - 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

batchSize

public MongoIterable<U> batchSize(int batchSize)

Description copied from interface: MongoIterable

Sets the number of documents to return per batch.

Specified by:

batchSize in interface MongoIterable<U>

Parameters:

batchSize - the batch size

Returns:

this

batchCursor

public void batchCursor(SingleResultCallback<AsyncBatchCursor<U>> callback)

Description copied from interface: MongoIterable

Provide the underlying AsyncBatchCursor allowing fine grained control of the cursor.

Specified by:

batchCursor in interface MongoIterable<U>

Parameters:

callback - a callback that will be passed the AsyncBatchCursor