trait ObserverFacade[T] extends Object with NextObserver[T] with ErrorObserver[T] with CompletionObserver[T]
Provides a mechanism for receiving push-based notifications.
After an Observer calls an rxscalajs.Observable's subscribe
method, the Observable
calls the Observer's onNext
method to provide notifications. A well-behaved Observable will
call an Observer's onCompleted
or onError
methods exactly once.
- Annotations
- @RawJSType() @native()
- Alphabetic
- By Inheritance
- ObserverFacade
- CompletionObserver
- ErrorObserver
- NextObserver
- Object
- Any
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
complete(): Unit
Notifies the Observer that the rxscalajs.Observable has finished sending push-based notifications.
Notifies the Observer that the rxscalajs.Observable has finished sending push-based notifications.
The rxscalajs.Observable will not call this method if it calls
onError
.- Definition Classes
- CompletionObserver
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
error(err: Any): Unit
Notifies the Observer that the rxscalajs.Observable has experienced an error condition.
Notifies the Observer that the rxscalajs.Observable has experienced an error condition.
If the rxscalajs.Observable calls this method, it will not thereafter call
onNext
oronCompleted
.- Definition Classes
- ErrorObserver
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hasOwnProperty(v: String): Boolean
- Definition Classes
- Object
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isPrototypeOf(v: Object): Boolean
- Definition Classes
- Object
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
next(t: T): Unit
Provides the Observer with new data.
Provides the Observer with new data.
The rxscalajs.Observable calls this closure 0 or more times.
The rxscalajs.Observable will not call this method again after it calls either
onCompleted
oronError
.- Definition Classes
- NextObserver
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
def
propertyIsEnumerable(v: String): Boolean
- Definition Classes
- Object
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toLocaleString(): String
- Definition Classes
- Object
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
valueOf(): Any
- Definition Classes
- Object
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )