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.  def _finally(finallySelector: Function0[Unit]): ObservableFacade[T]
5.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

6.  def audit[T2](durationSelector: Function1[T, Subscribable[T2]]): ObservableFacade[T]
7.  def auditTime(delay: Int, scheduler: Scheduler = ???): ObservableFacade[T]
8.  def buffer[T2](closingNotifier: ObservableFacade[T2]): ObservableFacade[Array[_ <: T]]
9.  def bufferCount(bufferSize: Int, startBufferEvery: Int = ???): ObservableFacade[Array[_ <: T]]
10.  def bufferTime(bufferTimeSpan: Int, bufferCreationInterval: Int = ???, scheduler: Scheduler = ???): ObservableFacade[Array[_ <: T]]
11.  def bufferToggle[T2, O](openings: Subscribable[O], closingSelector: Function1[O, Subscribable[T2]]): ObservableFacade[Array[_ <: T]]
12.  def bufferWhen[T2](closingSelector: Function0[ObservableFacade[T2]]): ObservableFacade[Array[_ <: T]]
13.  def catch[U](selector: Function1[Any, ObservableFacade[U]]): ObservableFacade[U]
14.  def clone(): AnyRef

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

15.  def combineAll[T2, R](project: Function1[Array[T2], R] = ???): ObservableFacade[R]
16.  def combineLatest[T2, R](v2: ObservableFacade[T2], project: Function2[T, T2, R] = ???): ObservableFacade[R]
17.  def concat[U >: T](that: ObservableFacade[U], scheduler: Scheduler = ???): ObservableFacade[U]
18.  def concatAll[U](): ObservableFacade[U]
19.  def concatMap[R](project: Function1[T, ObservableFacade[R]]): ObservableFacade[R]
20.  def concatMap[R](project: Function2[T, Int, ObservableFacade[R]]): ObservableFacade[R]
21.  def concatMap[I, R](project: Function2[T, Int, ObservableFacade[I]], resultSelector: Function4[T, I, Int, Int, R]): ObservableFacade[R]
22.  def concatMapTo[I, R](innerObservable: ObservableFacade[I], resultSelector: Function4[T, I, Int, Int, R] = ???): ObservableFacade[R]
23.  def count(predicate: Function3[T, Int, ObservableFacade[T], Boolean] = ???): ObservableFacade[Int]
24.  def debounce(durationSelector: Function1[T, Subscribable[Int]]): ObservableFacade[T]
25.  def debounceTime(dueTime: Int, scheduler: Scheduler = ???): ObservableFacade[T]
26.  def defaultIfEmpty[R](defaultValue: R): ObservableFacade[R]
27.  def delay(delay: |[Int, Date], scheduler: Scheduler = ???): ObservableFacade[T]
28.  def delayWhen[U, I](delayDurationSelector: Function1[T, ObservableFacade[U]], subscriptionDelay: ObservableFacade[I] = ???): ObservableFacade[T]
29.  def dematerialize[T2](): ObservableFacade[T2]
30.  def distinct[K, T2](keySelector: Function1[T, K] = ???, flushes: ObservableFacade[T2] = ???): ObservableFacade[T]
31.  def distinctUntilChanged(compare: Function2[T, T, Boolean] = ???): ObservableFacade[T]
32.  def distinctUntilChanged[K](compare: Function2[K, K, Boolean], keySelector: Function1[T, K]): ObservableFacade[T]
33.  def distinctUntilKeyChanged(key: String, compare: Function2[T, T, Boolean] = ???): ObservableFacade[T]
34.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

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

    Definition Classes

    AnyRef → Any

36.  def every[T2](predicate: Function2[T, Int, Boolean], thisArg: T2 = ???): ObservableFacade[Boolean]
37.  def exhaust[U](): ObservableFacade[U]
38.  def exhaustMap[I, R](project: Function2[T, Int, ObservableFacade[R]], resultSelector: Function4[T, I, Int, Int, R] = ???): ObservableFacade[R]
39.  def expand[R](project: Function2[T, Int, ObservableFacade[R]], concurrent: Double = ???, scheduler: Scheduler = ???): ObservableFacade[R]
40.  def filter[T2](predicate: Function1[T, Boolean]): ObservableFacade[T]
41.  def filter[T2](predicate: Function2[T, Int, Boolean], thisArg: T2 = ???): ObservableFacade[T]
42.  def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

43.  def find[T2](predicate: Function2[T, Int, Boolean], thisArg: T2 = ???): ObservableFacade[T]
44.  def findIndex[T2](predicate: Function2[T, Int, Boolean], thisArg: T2 = ???): ObservableFacade[Int]
45.  def first[R](predicate: Function2[T, Int, Boolean] = ???, resultSelector: Function2[T, Int, R] = ???, defaultValue: R = ???): ObservableFacade[R]
46.  def forEach(next: Function1[T, Unit], PromiseCtor: Promise.type = js.native): Promise[Unit]
47.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

48.  def groupBy[K, R, T2](keySelector: Function1[T, K], elementSelector: Function1[T, R] = ???, durationSelector: Function1[GroupedObservableFacade[K, R], ObservableFacade[T2]] = ???): ObservableFacade[GroupedObservableFacade[K, R]]
49.  def hasOwnProperty(v: String): Boolean

    Definition Classes

    Object

50.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

51.  def ignoreElements(): ObservableFacade[T]
52.  def isEmpty(): ObservableFacade[Boolean]
53.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

54.  def isPrototypeOf(v: Object): Boolean

    Definition Classes

    Object

55.  def last[R](predicate: Function3[T, Int, ObservableFacade[T], Boolean] = ???, resultSelector: Function2[T, Int, R] = ???, defaultValue: R = ???): ObservableFacade[R]
56.  def let[R](func: Function1[ObservableFacade[T], ObservableFacade[R]]): ObservableFacade[R]
57.  def map[R](project: Function1[T, R]): ObservableFacade[R]
58.  def mapTo[R](value: R): ObservableFacade[R]
59.  def mapWithIndex[R](project: Function2[T, Int, R]): ObservableFacade[R]

    Annotations

    @JSName( "map" )

60.  def materialize(): ObservableFacade[Notification[_ <: T]]
61.  def merge[R >: T](that: ObservableFacade[R], concurrent: Double = ???, scheduler: Scheduler = ???): ObservableFacade[R]
62.  def mergeAll[U](concurrent: Double = ???): ObservableFacade[U]
63.  def mergeMap[R](project: Function1[T, ObservableFacade[R]]): ObservableFacade[R]
64.  def mergeMap[R](project: Function2[T, Int, ObservableFacade[R]], resultSelector: Function4[T, R, Int, Int, R] = ???, concurrent: Double = ???): ObservableFacade[R]
65.  def mergeMapTo[I, R](innerObservable: ObservableFacade[I], resultSelector: Function4[T, I, Int, Int, R] = ???, concurrent: Double = ???): ObservableFacade[R]
66.  def mergeScan[R](project: Function2[R, T, ObservableFacade[R]], seed: R, concurrent: Int = ???): ObservableFacade[R]
67.  def multicast(subject: SubjectFacade[_ >: T]): ConnectableObservableFacade[T]
68.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

69.  final def notify(): Unit

    Definition Classes

    AnyRef

70.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

71.  def observeOn(scheduler: Scheduler, delay: Int = ???): ObservableFacade[T]
72.  def onErrorResumeNext[U >: T](resumeFunction: Function1[Any, ObservableFacade[U]]): ObservableFacade[U]
73.  def pairwise(): ObservableFacade[Array[_ <: T]]
74.  def partition[T2](predicate: Function1[T, Boolean], thisArg: T2 = ???): Array[_ <: ObservableFacade[T]]
75.  def pluck[R](properties: String*): ObservableFacade[R]
76.  def propertyIsEnumerable(v: String): Boolean

    Definition Classes

    Object

77.  def publish(): ConnectableObservableFacade[T]
78.  def publishBehavior(value: Any): ConnectableObservableFacade[T]
79.  def publishLast(): ConnectableObservableFacade[T]
80.  def publishReplay(bufferSize: Int = ???, windowTime: Double = ???, scheduler: Scheduler = ???): ConnectableObservableFacade[T]
81.  def race(observables: Array[_ >: ObservableFacade[T]]): ObservableFacade[T]
82.  def reduce[R](project: Function2[R, T, R], seed: R = ???): ObservableFacade[R]
83.  def repeat(scheduler: Scheduler = ???, count: Int = ???): ObservableFacade[T]
84.  def retry(count: Int = ???): ObservableFacade[T]
85.  def retryWhen[T2, T3](notifier: Function1[ObservableFacade[T2], ObservableFacade[T3]]): ObservableFacade[T]
86.  def sample[I](notifier: ObservableFacade[I]): ObservableFacade[T]
87.  def sampleTime(delay: Int, scheduler: Scheduler = ???): ObservableFacade[T]
88.  def scan[R](accumulator: Function2[R, T, R], seed: R = ???): ObservableFacade[R]
89.  def share(): ObservableFacade[T]
90.  def single(predicate: Function3[T, Int, ObservableFacade[T], Boolean] = ???): ObservableFacade[T]
91.  def skip(total: Int): ObservableFacade[T]
92.  def skipUntil[T2](notifier: ObservableFacade[T2]): ObservableFacade[T]
93.  def skipWhile(predicate: Function2[T, Int, Boolean]): ObservableFacade[T]
94.  var source: ObservableFacade[Any]
95.  def startWith[U >: T](v1: U, scheduler: Scheduler = ???): ObservableFacade[U]
96.  def subscribe(observer: ObserverFacade[_ >: T]): Subscription

    Definition Classes

    Subscribable

97.  def subscribe(onNext: Function1[T, Unit], error: Function1[Any, Unit] = ???, complete: Function0[Unit] = ???): Subscription

    Definition Classes

    Subscribable

98.  def subscribeOn(scheduler: Scheduler, delay: Int = ???): ObservableFacade[T]
99.  def switch(): T
100.  def switchMap[R](project: Function1[T, ObservableFacade[R]]): ObservableFacade[R]
101.  def switchMap[I, R](project: Function2[T, Int, ObservableFacade[I]], resultSelector: Function4[T, I, Int, Int, R] = ???): ObservableFacade[R]
102.  def switchMapTo[I, R](innerObservable: ObservableFacade[I], resultSelector: Function4[T, I, Int, Int, R] = ???): ObservableFacade[R]
103.  final def synchronized[T0](arg0: ⇒ T0): T0

     Definition Classes

     AnyRef

104.  def take(total: Int): ObservableFacade[T]
105.  def takeLast(total: Int): ObservableFacade[T]
106.  def takeUntil[T2](notifier: ObservableFacade[T2]): ObservableFacade[T]
107.  def takeWhile(predicate: Function2[T, Int, Boolean]): ObservableFacade[T]
108.  def throttle(durationSelector: Function1[T, Subscribable[Int]]): ObservableFacade[T]
109.  def throttleTime(delay: Int, scheduler: Scheduler = ???): ObservableFacade[T]
110.  def timeInterval(scheduler: Scheduler = ???): ObservableFacade[TimeInterval[T]]
111.  def timeout(due: |[Int, Date], scheduler: Scheduler = ???): ObservableFacade[T]
112.  def timeoutWith[R](due: |[Int, Date], withObservable: ObservableFacade[R], scheduler: Scheduler = ???): ObservableFacade[R]
113.  def timestamp(scheduler: Scheduler = ???): ObservableFacade[Timestamp[T]]
114.  def toArray(): ObservableFacade[Array[_ <: T]]
115.  def toLocaleString(): String

     Definition Classes

     Object

116.  def toString(): String

     Definition Classes

     AnyRef → Any

117.  def valueOf(): Any

     Definition Classes

     Object

118.  final def wait(): Unit

     Definition Classes

     AnyRef

     Annotations

     @throws( ... )

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

     Definition Classes

     AnyRef

     Annotations

     @throws( ... )

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

     Definition Classes

     AnyRef

     Annotations

     @throws( ... )

121.  def window[I](windowBoundaries: ObservableFacade[I]): ObservableFacade[ObservableFacade[T]]
122.  def windowCount(windowSize: Int, startWindowEvery: Int = ???): ObservableFacade[ObservableFacade[T]]
123.  def windowTime(windowTimeSpan: Int, windowCreationInterval: Int = ???, scheduler: Scheduler = ???): ObservableFacade[ObservableFacade[T]]
124.  def windowToggle[T2, O](openings: ObservableFacade[O], closingSelector: Function1[O, ObservableFacade[T2]]): ObservableFacade[ObservableFacade[T]]
125.  def windowWhen[T2](closingSelector: Function0[ObservableFacade[T2]]): ObservableFacade[ObservableFacade[T]]
126.  def withLatestFrom[T2, R](v2: ObservableFacade[T2], project: Function2[T, T2, R] = ???): ObservableFacade[R]
127.  def zip[T2, R](v2: ObservableFacade[T2], project: Function2[T, T2, R] = ???): ObservableFacade[R]
128.  def zipAll[T2, R](project: Function1[Array[T2], R] = ???): ObservableFacade[R]