class GroupedObservableFacade[K, T] extends ObservableFacade[T]
- Annotations
- @RawJSType() @native() @JSImport( "rxjs/Rx" , "GroupedObservable" , "Rx.GroupedObservable" )
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- GroupedObservableFacade
- ObservableFacade
- Subscribable
- Object
- Any
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new GroupedObservableFacade(key: K, groupSubject: SubjectFacade[T], refCountSubscription: Subscription)
-
new
GroupedObservableFacade()
- Attributes
- protected
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
-
def
_finally(finallySelector: Function0[Unit]): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
audit[T2](durationSelector: Function1[T, Subscribable[T2]]): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
auditTime(delay: Int, scheduler: Scheduler = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
buffer[T2](closingNotifier: ObservableFacade[T2]): ObservableFacade[Array[_ <: T]]
- Definition Classes
- ObservableFacade
-
def
bufferCount(bufferSize: Int, startBufferEvery: Int = ???): ObservableFacade[Array[_ <: T]]
- Definition Classes
- ObservableFacade
-
def
bufferTime(bufferTimeSpan: Int, bufferCreationInterval: Int = ???, scheduler: Scheduler = ???): ObservableFacade[Array[_ <: T]]
- Definition Classes
- ObservableFacade
-
def
bufferToggle[T2, O](openings: Subscribable[O], closingSelector: Function1[O, Subscribable[T2]]): ObservableFacade[Array[_ <: T]]
- Definition Classes
- ObservableFacade
-
def
bufferWhen[T2](closingSelector: Function0[ObservableFacade[T2]]): ObservableFacade[Array[_ <: T]]
- Definition Classes
- ObservableFacade
-
def
catch[U](selector: Function1[Any, ObservableFacade[U]]): ObservableFacade[U]
- Definition Classes
- ObservableFacade
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
combineAll[T2, R](project: Function1[Array[T2], R] = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
combineLatest[T2, R](v2: ObservableFacade[T2], project: Function2[T, T2, R] = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
concat[U >: T](that: ObservableFacade[U], scheduler: Scheduler = ???): ObservableFacade[U]
- Definition Classes
- ObservableFacade
-
def
concatAll[U](): ObservableFacade[U]
- Definition Classes
- ObservableFacade
-
def
concatMap[R](project: Function1[T, ObservableFacade[R]]): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
concatMap[R](project: Function2[T, Int, ObservableFacade[R]]): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
concatMap[I, R](project: Function2[T, Int, ObservableFacade[I]], resultSelector: Function4[T, I, Int, Int, R]): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
concatMapTo[I, R](innerObservable: ObservableFacade[I], resultSelector: Function4[T, I, Int, Int, R] = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
count(predicate: Function3[T, Int, ObservableFacade[T], Boolean] = ???): ObservableFacade[Int]
- Definition Classes
- ObservableFacade
-
def
debounce(durationSelector: Function1[T, Subscribable[Int]]): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
debounceTime(dueTime: Int, scheduler: Scheduler = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
defaultIfEmpty[R](defaultValue: R): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
delay(delay: |[Int, Date], scheduler: Scheduler = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
delayWhen[U, I](delayDurationSelector: Function1[T, ObservableFacade[U]], subscriptionDelay: ObservableFacade[I] = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
dematerialize[T2](): ObservableFacade[T2]
- Definition Classes
- ObservableFacade
-
def
distinct[K, T2](keySelector: Function1[T, K] = ???, flushes: ObservableFacade[T2] = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
distinctUntilChanged(compare: Function2[T, T, Boolean] = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
distinctUntilChanged[K](compare: Function2[K, K, Boolean], keySelector: Function1[T, K]): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
distinctUntilKeyChanged(key: String, compare: Function2[T, T, Boolean] = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
every[T2](predicate: Function2[T, Int, Boolean], thisArg: T2 = ???): ObservableFacade[Boolean]
- Definition Classes
- ObservableFacade
-
def
exhaust[U](): ObservableFacade[U]
- Definition Classes
- ObservableFacade
-
def
exhaustMap[I, R](project: Function2[T, Int, ObservableFacade[R]], resultSelector: Function4[T, I, Int, Int, R] = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
expand[R](project: Function2[T, Int, ObservableFacade[R]], concurrent: Double = ???, scheduler: Scheduler = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
filter[T2](predicate: Function1[T, Boolean]): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
filter[T2](predicate: Function2[T, Int, Boolean], thisArg: T2 = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
find[T2](predicate: Function2[T, Int, Boolean], thisArg: T2 = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
findIndex[T2](predicate: Function2[T, Int, Boolean], thisArg: T2 = ???): ObservableFacade[Int]
- Definition Classes
- ObservableFacade
-
def
first[R](predicate: Function2[T, Int, Boolean] = ???, resultSelector: Function2[T, Int, R] = ???, defaultValue: R = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
forEach(next: Function1[T, Unit], PromiseCtor: Promise.type = js.native): Promise[Unit]
- Definition Classes
- ObservableFacade
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
groupBy[K, R, T2](keySelector: Function1[T, K], elementSelector: Function1[T, R] = ???, durationSelector: Function1[GroupedObservableFacade[K, R], ObservableFacade[T2]] = ???): ObservableFacade[GroupedObservableFacade[K, R]]
- Definition Classes
- ObservableFacade
-
def
hasOwnProperty(v: String): Boolean
- Definition Classes
- Object
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
def
ignoreElements(): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
isEmpty(): ObservableFacade[Boolean]
- Definition Classes
- ObservableFacade
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isPrototypeOf(v: Object): Boolean
- Definition Classes
- Object
- val key: K
-
def
last[R](predicate: Function3[T, Int, ObservableFacade[T], Boolean] = ???, resultSelector: Function2[T, Int, R] = ???, defaultValue: R = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
let[R](func: Function1[ObservableFacade[T], ObservableFacade[R]]): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
map[R](project: Function1[T, R]): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
mapTo[R](value: R): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
mapWithIndex[R](project: Function2[T, Int, R]): ObservableFacade[R]
- Definition Classes
- ObservableFacade
- Annotations
- @JSName( "map" )
-
def
materialize(): ObservableFacade[Notification[_ <: T]]
- Definition Classes
- ObservableFacade
-
def
merge[R >: T](that: ObservableFacade[R], concurrent: Double = ???, scheduler: Scheduler = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
mergeAll[U](concurrent: Double = ???): ObservableFacade[U]
- Definition Classes
- ObservableFacade
-
def
mergeMap[R](project: Function1[T, ObservableFacade[R]]): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
mergeMap[R](project: Function2[T, Int, ObservableFacade[R]], resultSelector: Function4[T, R, Int, Int, R] = ???, concurrent: Double = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
mergeMapTo[I, R](innerObservable: ObservableFacade[I], resultSelector: Function4[T, I, Int, Int, R] = ???, concurrent: Double = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
mergeScan[R](project: Function2[R, T, ObservableFacade[R]], seed: R, concurrent: Int = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
multicast(subject: SubjectFacade[_ >: T]): ConnectableObservableFacade[T]
- Definition Classes
- ObservableFacade
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
def
observeOn(scheduler: Scheduler, delay: Int = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
onErrorResumeNext[U >: T](resumeFunction: Function1[Any, ObservableFacade[U]]): ObservableFacade[U]
- Definition Classes
- ObservableFacade
-
def
pairwise(): ObservableFacade[Array[_ <: T]]
- Definition Classes
- ObservableFacade
-
def
partition[T2](predicate: Function1[T, Boolean], thisArg: T2 = ???): Array[_ <: ObservableFacade[T]]
- Definition Classes
- ObservableFacade
-
def
pluck[R](properties: String*): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
propertyIsEnumerable(v: String): Boolean
- Definition Classes
- Object
-
def
publish(): ConnectableObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
publishBehavior(value: Any): ConnectableObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
publishLast(): ConnectableObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
publishReplay(bufferSize: Int = ???, windowTime: Double = ???, scheduler: Scheduler = ???): ConnectableObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
race(observables: Array[_ >: ObservableFacade[T]]): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
reduce[R](project: Function2[R, T, R], seed: R = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
repeat(scheduler: Scheduler = ???, count: Int = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
retry(count: Int = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
retryWhen[T2, T3](notifier: Function1[ObservableFacade[T2], ObservableFacade[T3]]): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
sample[I](notifier: ObservableFacade[I]): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
sampleTime(delay: Int, scheduler: Scheduler = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
scan[R](accumulator: Function2[R, T, R], seed: R = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
share(): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
single(predicate: Function3[T, Int, ObservableFacade[T], Boolean] = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
skip(total: Int): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
skipUntil[T2](notifier: ObservableFacade[T2]): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
skipWhile(predicate: Function2[T, Int, Boolean]): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
var
source: ObservableFacade[Any]
- Definition Classes
- ObservableFacade
-
def
startWith[U >: T](v1: U, scheduler: Scheduler = ???): ObservableFacade[U]
- Definition Classes
- ObservableFacade
-
def
subscribe(observer: ObserverFacade[_ >: T]): Subscription
- Definition Classes
- Subscribable
-
def
subscribe(onNext: Function1[T, Unit], error: Function1[Any, Unit] = ???, complete: Function0[Unit] = ???): Subscription
- Definition Classes
- Subscribable
-
def
subscribeOn(scheduler: Scheduler, delay: Int = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
switch(): T
- Definition Classes
- ObservableFacade
-
def
switchMap[R](project: Function1[T, ObservableFacade[R]]): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
switchMap[I, R](project: Function2[T, Int, ObservableFacade[I]], resultSelector: Function4[T, I, Int, Int, R] = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
switchMapTo[I, R](innerObservable: ObservableFacade[I], resultSelector: Function4[T, I, Int, Int, R] = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
take(total: Int): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
takeLast(total: Int): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
takeUntil[T2](notifier: ObservableFacade[T2]): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
takeWhile(predicate: Function2[T, Int, Boolean]): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
throttle(durationSelector: Function1[T, Subscribable[Int]]): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
throttleTime(delay: Int, scheduler: Scheduler = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
timeInterval(scheduler: Scheduler = ???): ObservableFacade[TimeInterval[T]]
- Definition Classes
- ObservableFacade
-
def
timeout(due: |[Int, Date], scheduler: Scheduler = ???): ObservableFacade[T]
- Definition Classes
- ObservableFacade
-
def
timeoutWith[R](due: |[Int, Date], withObservable: ObservableFacade[R], scheduler: Scheduler = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
timestamp(scheduler: Scheduler = ???): ObservableFacade[Timestamp[T]]
- Definition Classes
- ObservableFacade
-
def
toArray(): ObservableFacade[Array[_ <: T]]
- Definition Classes
- ObservableFacade
-
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( ... )
-
def
window[I](windowBoundaries: ObservableFacade[I]): ObservableFacade[ObservableFacade[T]]
- Definition Classes
- ObservableFacade
-
def
windowCount(windowSize: Int, startWindowEvery: Int = ???): ObservableFacade[ObservableFacade[T]]
- Definition Classes
- ObservableFacade
-
def
windowTime(windowTimeSpan: Int, windowCreationInterval: Int = ???, scheduler: Scheduler = ???): ObservableFacade[ObservableFacade[T]]
- Definition Classes
- ObservableFacade
-
def
windowToggle[T2, O](openings: ObservableFacade[O], closingSelector: Function1[O, ObservableFacade[T2]]): ObservableFacade[ObservableFacade[T]]
- Definition Classes
- ObservableFacade
-
def
windowWhen[T2](closingSelector: Function0[ObservableFacade[T2]]): ObservableFacade[ObservableFacade[T]]
- Definition Classes
- ObservableFacade
-
def
withLatestFrom[T2, R](v2: ObservableFacade[T2], project: Function2[T, T2, R] = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
zip[T2, R](v2: ObservableFacade[T2], project: Function2[T, T2, R] = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade
-
def
zipAll[T2, R](project: Function1[Array[T2], R] = ???): ObservableFacade[R]
- Definition Classes
- ObservableFacade