class BehaviorSubjectFacade[T] extends SubjectFacade[T]
- Annotations
- @RawJSType() @native() @JSImport( "rxjs/Rx" , "BehaviorSubject" , "Rx.BehaviorSubject" )
- Alphabetic
- By Inheritance
- BehaviorSubjectFacade
- SubjectFacade
- ObserverFacade
- CompletionObserver
- ErrorObserver
- NextObserver
- AnonymousSubscription
- ObservableFacade
- Subscribable
- Object
- Any
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
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
asObservable(): ObservableFacade[T]
- Definition Classes
- SubjectFacade
-
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
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
- SubjectFacade → CompletionObserver
-
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
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
- SubjectFacade → ErrorObserver
-
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 getValue(): T
-
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
-
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
-
def
next(value: 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
- SubjectFacade → NextObserver
-
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
throwIfUnsubscribed(): Dynamic
- Definition Classes
- SubjectFacade
-
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
unsubscribe(): Unit
Call this method to stop receiving notifications on the Observer that was registered when this Subscription was received.
Call this method to stop receiving notifications on the Observer that was registered when this Subscription was received.
- Definition Classes
- AnonymousSubscription
- var value: T
-
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