Mongo Scala Driver - org.mongodb.scala.AggregateObservable (original) (raw)

case class AggregateObservable[TResult](wrapped: AggregateIterable[TResult]) extends Observable[TResult] with Product with Serializable

 

Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. AggregateObservable

2. Serializable

3. Product

4. Equals

5. Observable

6. Observable

7. AnyRef

8. Any

9. Hide All

10. Show All

Visibility

1. Public
2. Protected

Value Members

1.  final def !=(arg0: Any): Boolean
2.  final def ##(): Int
3.  final def ==(arg0: Any): Boolean
4.  def allowDiskUse(allowDiskUse: Boolean): AggregateObservable[TResult]
5.  final def asInstanceOf[T0]: T0
6.  def batchSize(batchSize: Int): AggregateObservable[TResult]
7.  def bypassDocumentValidation(bypassDocumentValidation: Boolean): AggregateObservable[TResult]
8.  def clone(): AnyRef
9.  def collation(collation: Collation): AggregateObservable[TResult]
10.  def comment(comment: String): AggregateObservable[TResult]
11.  final def eq(arg0: AnyRef): Boolean
12.  def finalize(): Unit
13.  final def getClass(): Class[_ <: AnyRef]
14.  def hint(hint: Bson): AggregateObservable[TResult]
15.  final def isInstanceOf[T0]: Boolean
16.  def maxAwaitTime(duration: Duration): AggregateObservable[TResult]
17.  def maxTime(duration: Duration): AggregateObservable[TResult]
18.  final def ne(arg0: AnyRef): Boolean
19.  final def notify(): Unit
20.  final def notifyAll(): Unit
21.  def productElementNames: Iterator[String]
22.  def subscribe(observer: Observer[_ >: TResult]): Unit
23.  def subscribe(observer: com.mongodb.async.client.Observer[_ >: TResult]): Unit
24.  final def synchronized[T0](arg0: => T0): T0
25.  def toCollection(): Observable[Completed]
26.  final def wait(): Unit
27.  final def wait(arg0: Long, arg1: Int): Unit
28.  final def wait(arg0: Long): Unit

Ungrouped