com.mongodb.async.client

Class MappingAsyncBatchCursor<T,U>

java.lang.Object

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

All Implemented Interfaces:

AsyncBatchCursor<U>, java.io.Closeable, java.lang.AutoCloseable

class MappingAsyncBatchCursor<T,U>
extends java.lang.Object
implements AsyncBatchCursor<U>

Field Summary

Fields

Modifier and Type	Field and Description
private AsyncBatchCursor<T>	batchCursor
private Function<T,U>	mapper

Constructor Summary

Constructors

Constructor and Description
MappingAsyncBatchCursor(AsyncBatchCursor<T> batchCursor, Function<T,U> mapper)

Method Summary

Modifier and Type	Method and Description
void	close()
int	getBatchSize() Gets the batch size to use when requesting the next batch.
boolean	isClosed() Return true if the AsyncBatchCursor has been closed
void	next(SingleResultCallback<java.util.List<U>> callback) Returns the next batch of results.
void	setBatchSize(int batchSize) Sets the batch size to use when requesting the next batch.

Methods inherited from class java.lang.Object

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

Field Detail

batchCursor

private final AsyncBatchCursor<T> batchCursor

mapper

private final Function<T,U> mapper

Constructor Detail

MappingAsyncBatchCursor

MappingAsyncBatchCursor(AsyncBatchCursor<T> batchCursor,
                        Function<T,U> mapper)

Method Detail

next

public void next(SingleResultCallback<java.util.List<U>> callback)

Description copied from interface: AsyncBatchCursor

Returns the next batch of results. A tailable cursor will block until another batch exists. After the last batch, the next call to this method will execute the callback with a null result to indicate that there are no more batches available and the cursor has been closed.

Specified by:

next in interface AsyncBatchCursor<U>

Parameters:

callback - callback to receive the next batch of results

setBatchSize

public void setBatchSize(int batchSize)

Description copied from interface: AsyncBatchCursor

Sets the batch size to use when requesting the next batch. This is the number of documents to request in the next batch.

Specified by:

setBatchSize in interface AsyncBatchCursor<U>

Parameters:

batchSize - the non-negative batch size. 0 means to use the server default.

getBatchSize

public int getBatchSize()

Description copied from interface: AsyncBatchCursor

Gets the batch size to use when requesting the next batch. This is the number of documents to request in the next batch.

Specified by:

getBatchSize in interface AsyncBatchCursor<U>

Returns:

the non-negative batch size. 0 means to use the server default.

isClosed

public boolean isClosed()

Description copied from interface: AsyncBatchCursor

Return true if the AsyncBatchCursor has been closed

Specified by:

isClosed in interface AsyncBatchCursor<U>

Returns:

true if the AsyncBatchCursor has been closed

close

public void close()

Specified by:

close in interface AsyncBatchCursor<U>

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable