case class FindObservable[TResult](wrapped: FindIterable[TResult]) extends Observable[TResult] with Product with Serializable
Observable interface for Find.
- TResult
The type of the result.
- wrapped
the underlying java FindObservable
- Since
1.0
- Alphabetic
- By Inheritance
- FindObservable
- Serializable
- Serializable
- Product
- Equals
- Observable
- Observable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
FindObservable(wrapped: FindIterable[TResult])
- wrapped
the underlying java FindObservable
Value Members
-
def
collation(collation: Collation): FindObservable[TResult]
Sets the collation options
Sets the collation options
- collation
the collation options to use
- returns
this
- Since
1.2
- Note
Requires MongoDB 3.4 or greater
,A null value represents the server default.
-
def
cursorType(cursorType: CursorType): FindObservable[TResult]
Sets the cursor type.
Sets the cursor type.
- cursorType
the cursor type
- returns
this
-
def
filter(filter: Bson): FindObservable[TResult]
Sets the query filter to apply to the query.
Sets the query filter to apply to the query.
- filter
the filter, which may be null.
- returns
this
-
def
first(): SingleObservable[TResult]
Helper to return a Observable limited to just the first result the query.
Helper to return a Observable limited to just the first result the query.
**Note:** Sets limit in the background so only returns 1.
- returns
a Observable which will return the first item
-
def
limit(limit: Int): FindObservable[TResult]
Sets the limit to apply.
Sets the limit to apply.
- limit
the limit, which may be null
- returns
this
-
def
maxAwaitTime(duration: Duration): FindObservable[TResult]
The maximum amount of time for the server to wait on new documents to satisfy a tailable cursor query.
The maximum amount of time for the server to wait on new documents to satisfy a tailable cursor query. This only applies to a TAILABLE_AWAIT cursor. When the cursor is not a TAILABLE_AWAIT cursor, this option is ignored.
On servers >= 3.2, this option will be specified on the getMore command as "maxTimeMS". The default is no value: no "maxTimeMS" is sent to the server with the getMore command.
On servers < 3.2, this option is ignored, and indicates that the driver should respect the server's default value
A zero value will be ignored.
- duration
the duration
- returns
the maximum await execution time in the given time unit
- Since
1.1
-
def
maxTime(duration: Duration): FindObservable[TResult]
Sets the maximum execution time on the server for this operation.
Sets the maximum execution time on the server for this operation.
- duration
the duration
- returns
this
-
def
modifiers(modifiers: Bson): FindObservable[TResult]
Sets the query modifiers to apply to this operation.
Sets the query modifiers to apply to this operation.
- modifiers
the query modifiers to apply, which may be null.
- returns
this
-
def
noCursorTimeout(noCursorTimeout: Boolean): FindObservable[TResult]
The server normally times out idle cursors after an inactivity period (10 minutes) to prevent excess memory use.
The server normally times out idle cursors after an inactivity period (10 minutes) to prevent excess memory use. Set this option to prevent that.
- noCursorTimeout
true if cursor timeout is disabled
- returns
this
-
def
oplogReplay(oplogReplay: Boolean): FindObservable[TResult]
Users should not set this under normal circumstances.
Users should not set this under normal circumstances.
- oplogReplay
if oplog replay is enabled
- returns
this
-
def
partial(partial: Boolean): FindObservable[TResult]
Get partial results from a sharded cluster if one or more shards are unreachable (instead of throwing an error).
Get partial results from a sharded cluster if one or more shards are unreachable (instead of throwing an error).
- partial
if partial results for sharded clusters is enabled
- returns
this
-
def
projection(projection: Bson): FindObservable[TResult]
Sets a document describing the fields to return for all matching documents.
Sets a document describing the fields to return for all matching documents.
- projection
the project document, which may be null.
- returns
this
-
def
skip(skip: Int): FindObservable[TResult]
Sets the number of documents to skip.
Sets the number of documents to skip.
- skip
the number of documents to skip
- returns
this
-
def
sort(sort: Bson): FindObservable[TResult]
Sets the sort criteria to apply to the query.
Sets the sort criteria to apply to the query.
- sort
the sort criteria, which may be null.
- returns
this
-
def
subscribe(observer: Observer[_ >: TResult]): Unit
Request
Observableto start streaming data.Request
Observableto start streaming data.This is a "factory method" and can be called multiple times, each time starting a new Subscription. Each
Subscriptionwill work for only a single Observer.If the
Observablerejects the subscription attempt or otherwise fails it will signal the error via Observer.onError.- observer
the
Observerthat will consume signals from thisObservable
- Definition Classes
- FindObservable → Observable
-
def
subscribe(observer: com.mongodb.async.client.Observer[_ >: TResult]): Unit
Handles the automatic boxing of a Java
Observableso it conforms to the interface.Handles the automatic boxing of a Java
Observableso it conforms to the interface.- observer
the
Observerthat will consume signals from thisObservable
- Definition Classes
- Observable → Observable
- Note
Users should not have to implement this method but rather use the Scala
Observable.
This is the documentation for the MongoDB Scala driver.
Driver structure
The mongodb scala driver.
To get started you need a MongoClient instance, either from a connection string or via a org.mongodb.scala.MongoClientSettings.
Notable packages include: