com.mongodb.operation

Class AsyncChangeStreamBatchCursor<T>

java.lang.Object

com.mongodb.operation.AsyncChangeStreamBatchCursor<T>

All Implemented Interfaces:

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

final class AsyncChangeStreamBatchCursor<T>
extends java.lang.Object
implements AsyncBatchCursor<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static interface	AsyncChangeStreamBatchCursor.AsyncBlock

Field Summary

Fields

Modifier and Type	Field and Description
private AsyncReadBinding	binding
private ChangeStreamOperation<T>	changeStreamOperation
private BsonDocument	resumeToken
private AsyncBatchCursor<RawBsonDocument>	wrapped

Constructor Summary

Constructors

Constructor and Description
AsyncChangeStreamBatchCursor(ChangeStreamOperation<T> changeStreamOperation, AsyncBatchCursor<RawBsonDocument> wrapped, AsyncReadBinding binding)

Method Summary

Modifier and Type	Method and Description
void	close()
private SingleResultCallback<java.util.List<RawBsonDocument>>	convertResultsCallback(SingleResultCallback<java.util.List<T>> callback)
int	getBatchSize() Gets the batch size to use when requesting the next batch.
(package private) AsyncBatchCursor<RawBsonDocument>	getWrapped()
boolean	isClosed() Return true if the AsyncBatchCursor has been closed
void	next(SingleResultCallback<java.util.List<T>> callback) Returns the next batch of results.
private void	resumeableOperation(AsyncChangeStreamBatchCursor.AsyncBlock asyncBlock, SingleResultCallback<java.util.List<RawBsonDocument>> callback)
private void	retryOperation(AsyncChangeStreamBatchCursor.AsyncBlock asyncBlock, SingleResultCallback<java.util.List<RawBsonDocument>> callback)
void	setBatchSize(int batchSize) Sets the batch size to use when requesting the next batch.
void	tryNext(SingleResultCallback<java.util.List<T>> callback) A special next() case that returns the next batch if available or null.

Methods inherited from class java.lang.Object

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

Field Detail

binding

private final AsyncReadBinding binding

changeStreamOperation

private final ChangeStreamOperation<T> changeStreamOperation

resumeToken

private volatile BsonDocument resumeToken

wrapped

private volatile AsyncBatchCursor<RawBsonDocument> wrapped

Constructor Detail

AsyncChangeStreamBatchCursor

AsyncChangeStreamBatchCursor(ChangeStreamOperation<T> changeStreamOperation,
                             AsyncBatchCursor<RawBsonDocument> wrapped,
                             AsyncReadBinding binding)

Method Detail

getWrapped

AsyncBatchCursor<RawBsonDocument> getWrapped()

next

public void next(SingleResultCallback<java.util.List<T>> 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<T>

Parameters:

callback - callback to receive the next batch of results

tryNext

public void tryNext(SingleResultCallback<java.util.List<T>> callback)

Description copied from interface: AsyncBatchCursor

A special next() case that returns the next batch if available or null.

Tailable cursors are an example where this is useful. A call to tryNext() may return null, but in the future calling tryNext() would return a new batch if a document had been added to the capped collection.

Specified by:

tryNext in interface AsyncBatchCursor<T>

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

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

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

Returns:

true if the AsyncBatchCursor has been closed

close

public void close()

Specified by:

close in interface AsyncBatchCursor<T>

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

resumeableOperation

private void resumeableOperation(AsyncChangeStreamBatchCursor.AsyncBlock asyncBlock,
                                 SingleResultCallback<java.util.List<RawBsonDocument>> callback)

retryOperation

private void retryOperation(AsyncChangeStreamBatchCursor.AsyncBlock asyncBlock,
                            SingleResultCallback<java.util.List<RawBsonDocument>> callback)

convertResultsCallback

private SingleResultCallback<java.util.List<RawBsonDocument>> convertResultsCallback(SingleResultCallback<java.util.List<T>> callback)