com.mongodb.rx.client

Interface FindObservable<TResult>

Type Parameters:

TResult - The type of the result.

All Superinterfaces:

MongoObservable<TResult>

public interface FindObservable<TResult>
extends MongoObservable<TResult>

MongoObservable interface for find.

Since:

1.0

Method Summary

Modifier and Type	Method and Description
FindObservable<TResult>	cursorType(com.mongodb.CursorType cursorType) Sets the cursor type.
FindObservable<TResult>	filter(org.bson.conversions.Bson filter) Sets the query filter to apply to the query.
rx.Observable<TResult>	first() Helper to return an Observable limited first from the query.
FindObservable<TResult>	limit(int limit) Sets the limit to apply.
FindObservable<TResult>	maxTime(long maxTime, TimeUnit timeUnit) Sets the maximum execution time on the server for this operation.
FindObservable<TResult>	modifiers(org.bson.conversions.Bson modifiers) Sets the query modifiers to apply to this operation.
FindObservable<TResult>	noCursorTimeout(boolean noCursorTimeout) The server normally times out idle cursors after an inactivity period (10 minutes) to prevent excess memory use.
FindObservable<TResult>	oplogReplay(boolean oplogReplay) Users should not set this under normal circumstances.
FindObservable<TResult>	partial(boolean partial) Get partial results from a sharded cluster if one or more shards are unreachable (instead of throwing an error).
FindObservable<TResult>	projection(org.bson.conversions.Bson projection) Sets a document describing the fields to return for all matching documents.
FindObservable<TResult>	skip(int skip) Sets the number of documents to skip.
FindObservable<TResult>	sort(org.bson.conversions.Bson sort) Sets the sort criteria to apply to the query.

Methods inherited from interface com.mongodb.rx.client.MongoObservable

subscribe, toObservable

Method Detail

first

rx.Observable<TResult> first()

Helper to return an Observable limited first from the query.

Returns:

an Observable which will

filter

FindObservable<TResult> filter(org.bson.conversions.Bson filter)

Sets the query filter to apply to the query.

Parameters:

filter - the filter, which may be null.

Returns:

this

MongoDB documentation

Filter

limit

FindObservable<TResult> limit(int limit)

Sets the limit to apply.

Parameters:

limit - the limit, which may be null

Returns:

this

MongoDB documentation

Limit

skip

FindObservable<TResult> skip(int skip)

Sets the number of documents to skip.

Parameters:

skip - the number of documents to skip

Returns:

this

MongoDB documentation

Skip

maxTime

FindObservable<TResult> maxTime(long maxTime,
                                TimeUnit timeUnit)

Sets the maximum execution time on the server for this operation.

Parameters:

maxTime - the max time

timeUnit - the time unit, which may not be null

Returns:

this

MongoDB documentation

Max Time

modifiers

FindObservable<TResult> modifiers(org.bson.conversions.Bson modifiers)

Sets the query modifiers to apply to this operation.

Parameters:

modifiers - the query modifiers to apply, which may be null.

Returns:

this

MongoDB documentation

Query Modifiers

projection

FindObservable<TResult> projection(org.bson.conversions.Bson projection)

Sets a document describing the fields to return for all matching documents.

Parameters:

projection - the project document, which may be null.

Returns:

this

MongoDB documentation

Projection

sort

FindObservable<TResult> sort(org.bson.conversions.Bson sort)

Sets the sort criteria to apply to the query.

Parameters:

sort - the sort criteria, which may be null.

Returns:

this

MongoDB documentation

Sort

noCursorTimeout

FindObservable<TResult> noCursorTimeout(boolean noCursorTimeout)

The server normally times out idle cursors after an inactivity period (10 minutes) to prevent excess memory use. Set this option to prevent that.

Parameters:

noCursorTimeout - true if cursor timeout is disabled

Returns:

this

oplogReplay

FindObservable<TResult> oplogReplay(boolean oplogReplay)

Users should not set this under normal circumstances.

Parameters:

oplogReplay - if oplog replay is enabled

Returns:

this

partial

FindObservable<TResult> partial(boolean partial)

Get partial results from a sharded cluster if one or more shards are unreachable (instead of throwing an error).

Parameters:

partial - if partial results for sharded clusters is enabled

Returns:

this

cursorType

FindObservable<TResult> cursorType(com.mongodb.CursorType cursorType)

Sets the cursor type.

Parameters:

cursorType - the cursor type

Returns:

this