Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

6.  final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

7.  def equals(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

8.  def finalize(): Unit

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( classOf[java.lang.Throwable] )

9.  final def getClass(): Class[_]

   Definition Classes

   AnyRef → Any

10.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

11.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

12.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

13.  final def notify(): Unit

    Definition Classes

    AnyRef

14.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

15.  def onComplete(): Unit

    Notifies the Subscriber that the Observable has finished sending push-based notifications.

    Notifies the Subscriber that the Observable has finished sending push-based notifications.

    The Observable will not call this method if it calls onError.

    Definition Classes

    BoxedObserver → Observer → Observer

16.  def onError(e: Throwable): Unit

    Notifies the Observer that the Observable has experienced an error condition.

    Notifies the Observer that the Observable has experienced an error condition.

    If the Observable calls this method, it will not thereafter call onNext or onComplete.

    e

    the exception encountered by the Observable

    Definition Classes

    BoxedObserver → Observer → Observer

17.  def onNext(result: T): Unit

    Provides the Observer with a new item to observe.

    Provides the Observer with a new item to observe.

    The Observer may call this method 0 or more times.

    The Observable will not call this method again after it calls either onComplete or onError.

    result

    the item emitted by the Observable

    Definition Classes

    BoxedObserver → Observer → Observer

18.  def onSubscribe(subscription: Subscription): Unit

    Invoked on subscription to an Observable.

    Invoked on subscription to an Observable.

    No operation will happen until Subscription.request is invoked.

    It is the responsibility of this Subscriber instance to call Subscription.request whenever more data is wanted.

    subscription

    Subscription that allows requesting data via Subscription.request

    Definition Classes

    BoxedObserver → Observer

19.  def onSubscribe(subscription: com.mongodb.async.client.Subscription): Unit

    Handles the automatic boxing of a Java subscription so it conforms to the interface.

    Handles the automatic boxing of a Java subscription so it conforms to the interface.

    subscription

    the Java subscription

    Definition Classes

    Observer → Observer

    Note

    Users should not have to implement this method but rather use the Scala Subscription.

20.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

21.  def toString(): String

    Definition Classes

    AnyRef → Any

22.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

23.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

24.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )