TResult
- The type of the result.public interface AggregateObservable<TResult> extends MongoObservable<TResult>
Modifier and Type | Method and Description |
---|---|
AggregateObservable<TResult> |
allowDiskUse(Boolean allowDiskUse)
Enables writing to temporary files.
|
AggregateObservable<TResult> |
maxTime(long maxTime,
TimeUnit timeUnit)
Sets the maximum execution time on the server for this operation.
|
rx.Observable<Success> |
toCollection()
Aggregates documents according to the specified aggregation pipeline, which must end with a $out stage.
|
AggregateObservable<TResult> |
useCursor(Boolean useCursor)
Sets whether the server should use a cursor to return results.
|
subscribe, toObservable
AggregateObservable<TResult> allowDiskUse(Boolean allowDiskUse)
allowDiskUse
- true if writing to temporary files is enabledAggregateObservable<TResult> maxTime(long maxTime, TimeUnit timeUnit)
maxTime
- the max timetimeUnit
- the time unit, which may not be nullAggregateObservable<TResult> useCursor(Boolean useCursor)
useCursor
- whether the server should use a cursor to return resultsrx.Observable<Success> toCollection()