com.mongodb.async.client

Class AggregateToCollectionThenFindOperation<T>

java.lang.Object

com.mongodb.async.client.AggregateToCollectionThenFindOperation<T>

All Implemented Interfaces:

AsyncReadOperation<AsyncBatchCursor<T>>

class AggregateToCollectionThenFindOperation<T>
extends java.lang.Object
implements AsyncReadOperation<AsyncBatchCursor<T>>

Field Summary

Fields

Modifier and Type	Field and Description
private AsyncWriteOperation<java.lang.Void>	aggregateToCollectionOperation
private FindOperation<T>	findOperation

Constructor Summary

Constructors

Constructor and Description
AggregateToCollectionThenFindOperation(AsyncWriteOperation<java.lang.Void> aggregateToCollectionOperation, FindOperation<T> findOperation)

Method Summary

Modifier and Type	Method and Description
void	executeAsync(AsyncReadBinding binding, SingleResultCallback<AsyncBatchCursor<T>> callback) General execute which can return anything of type T
AsyncWriteOperation<java.lang.Void>	getAggregateToCollectionOperation()
FindOperation<T>	getFindOperation()

Methods inherited from class java.lang.Object

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

Field Detail

aggregateToCollectionOperation

private final AsyncWriteOperation<java.lang.Void> aggregateToCollectionOperation

findOperation

private final FindOperation<T> findOperation

Constructor Detail

AggregateToCollectionThenFindOperation

AggregateToCollectionThenFindOperation(AsyncWriteOperation<java.lang.Void> aggregateToCollectionOperation,
                                       FindOperation<T> findOperation)

Method Detail

getAggregateToCollectionOperation

public AsyncWriteOperation<java.lang.Void> getAggregateToCollectionOperation()

getFindOperation

public FindOperation<T> getFindOperation()

executeAsync

public void executeAsync(AsyncReadBinding binding,
                         SingleResultCallback<AsyncBatchCursor<T>> callback)

Description copied from interface: AsyncReadOperation

General execute which can return anything of type T

Specified by:

executeAsync in interface AsyncReadOperation<AsyncBatchCursor<T>>

Parameters:

binding - the binding to execute in the context of

callback - the callback to be called when the operation has been executed