BehaviorSubject

java.lang.Object
- rx.Observable<R>
- - rx.subjects.Subject<T,T>
  - - rx.subjects.BehaviorSubject<T>

Type Parameters:: T - the type of item expected to be observed by the Subject

All Implemented Interfaces:: Observer<T>

public final class BehaviorSubject<T>
extends Subject<T,T>

Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.

Example usage:

  // observer will receive all events. BehaviorSubject<Object> subject = BehaviorSubject.create("default"); subject.subscribe(observer); subject.onNext("one"); subject.onNext("two"); subject.onNext("three"); // observer will receive the "one", "two" and "three" events, but not "zero" BehaviorSubject<Object> subject = BehaviorSubject.create("default"); subject.onNext("zero"); subject.onNext("one"); subject.subscribe(observer); subject.onNext("two"); subject.onNext("three"); // observer will receive only onCompleted BehaviorSubject<Object> subject = BehaviorSubject.create("default"); subject.onNext("zero"); subject.onNext("one"); subject.onCompleted(); subject.subscribe(observer); // observer will receive only onError BehaviorSubject<Object> subject = BehaviorSubject.create("default"); subject.onNext("zero"); subject.onNext("one"); subject.onError(new RuntimeException("error")); subject.subscribe(observer);

Nested Class Summary
- Nested classes/interfaces inherited from class rx.Observable
  Observable.OnSubscribe<T>, Observable.Operator<R,T>, Observable.Transformer<T,R>

Constructor Summary

Constructors

Modifier	Constructor and Description
`protected`	`BehaviorSubject(Observable.OnSubscribe<T> onSubscribe, rx.subjects.SubjectSubscriptionManager<T> state)`

Method Summary

All Methods

Static Methods

Instance Methods

Concrete Methods
Modifier and Type	Method and Description
`static <T> BehaviorSubject<T>`	`create()` Creates a `BehaviorSubject` without a default item.
`static <T> BehaviorSubject<T>`	`create(T defaultValue)` Creates a `BehaviorSubject` that emits the last item it observed and all subsequent items to each `Observer` that subscribes to it.
`boolean`	`hasObservers()` Indicates whether the `Subject` has `Observers` subscribed to it.
`void`	`onCompleted()` Notifies the Observer that the `Observable` has finished sending push-based notifications.
`void`	`onError(Throwable e)` Notifies the Observer that the `Observable` has experienced an error condition.
`void`	`onNext(T v)` Provides the Observer with a new item to observe.

Methods inherited from class rx.subjects.Subject
toSerialized

Methods inherited from class rx.Observable
all, amb, amb, amb, amb, amb, amb, amb, amb, amb, ambWith, asObservable, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, cache, cache, cast, collect, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, compose, concat, concat, concat, concat, concat, concat, concat, concat, concat, concatMap, concatWith, contains, count, countLong, debounce, debounce, debounce, defaultIfEmpty, defer, delay, delay, delay, delay, delaySubscription, delaySubscription, delaySubscription, dematerialize, distinct, distinct, distinctUntilChanged, distinctUntilChanged, doOnCompleted, doOnEach, doOnEach, doOnError, doOnNext, doOnSubscribe, doOnTerminate, doOnUnsubscribe, elementAt, elementAtOrDefault, empty, error, exists, filter, finallyDo, first, first, firstOrDefault, firstOrDefault, flatMap, flatMap, flatMap, flatMapIterable, flatMapIterable, forEach, forEach, forEach, from, from, from, from, from, groupBy, groupBy, groupJoin, ignoreElements, interval, interval, isEmpty, join, just, just, just, just, just, just, just, just, just, just, last, last, lastOrDefault, lastOrDefault, lift, limit, map, materialize, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, nest, never, observeOn, ofType, onBackpressureBuffer, onBackpressureDrop, onErrorResumeNext, onErrorResumeNext, onErrorReturn, onExceptionResumeNext, publish, publish, range, range, reduce, reduce, repeat, repeat, repeat, repeat, repeatWhen, repeatWhen, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, retry, retry, retry, retryWhen, retryWhen, sample, sample, sample, scan, scan, sequenceEqual, sequenceEqual, serialize, share, single, single, singleOrDefault, singleOrDefault, skip, skip, skip, skipLast, skipLast, skipLast, skipUntil, skipWhile, startWith, startWith, startWith, startWith, startWith, startWith, startWith, startWith, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, switchMap, switchOnNext, take, take, take, takeFirst, takeLast, takeLast, takeLast, takeLast, takeLast, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeUntil, takeWhile, throttleFirst, throttleFirst, throttleLast, throttleLast, throttleWithTimeout, throttleWithTimeout, timeInterval, timeInterval, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timer, timer, timer, timer, timestamp, timestamp, toBlocking, toList, toMap, toMap, toMap, toMultimap, toMultimap, toMultimap, toMultimap, toSortedList, toSortedList, unsafeSubscribe, unsubscribeOn, using, window, window, window, window, window, window, window, window, window, window, window, window, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipWith, zipWith

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - BehaviorSubject
```
protected BehaviorSubject(Observable.OnSubscribe<T> onSubscribe,
                          rx.subjects.SubjectSubscriptionManager<T> state)
```
- Method Detail
  - create
```
public static <T> BehaviorSubject<T> create()
```
    Creates a BehaviorSubject without a default item.
    
    Type Parameters:
    
    T - the type of item the Subject will emit
    
    Returns:
    
    the constructed BehaviorSubject
  - create
```
public static <T> BehaviorSubject<T> create(T defaultValue)
```
    Creates a BehaviorSubject that emits the last item it observed and all subsequent items to each Observer that subscribes to it.
    
    Type Parameters:
    
    T - the type of item the Subject will emit
    
    Parameters:
    
    defaultValue - the item that will be emitted first to any Observer as long as the BehaviorSubject has not yet observed any items from its source Observable
    
    Returns:
    
    the constructed BehaviorSubject
  - onCompleted
```
public void onCompleted()
```
    Description copied from interface: Observer
    
    Notifies the Observer that the Observable has finished sending push-based notifications.
    The Observable will not call this method if it calls Observer.onError(java.lang.Throwable).
  - onError
```
public void onError(Throwable e)
```
    Description copied from interface: Observer
    
    Notifies the Observer that the Observable has experienced an error condition.
    If the Observable calls this method, it will not thereafter call Observer.onNext(T) or Observer.onCompleted().
    
    Parameters:
    
    e - the exception encountered by the Observable
  - onNext
```
public void onNext(T v)
```
    Description copied from interface: Observer
    
    Provides the Observer with a new item to observe.
    The Observable may call this method 0 or more times.
    
    The Observable will not call this method again after it calls either Observer.onCompleted() or Observer.onError(java.lang.Throwable).
    
    Parameters:
    
    v - the item emitted by the Observable
  - hasObservers
```
public boolean hasObservers()
```
    Description copied from class: Subject
    
    Indicates whether the Subject has Observers subscribed to it.
    
    Specified by:
    
    hasObservers in class Subject<T,T>
    
    Returns:
    
    true if there is at least one Observer subscribed to this Subject, false otherwise

Class BehaviorSubject<T>

Nested Class Summary

Nested classes/interfaces inherited from class rx.Observable

Constructor Summary

Constructors

Method Summary

Methods inherited from class rx.subjects.Subject

Methods inherited from class rx.Observable

Methods inherited from class java.lang.Object

Constructor Detail

BehaviorSubject

Method Detail

create

create

onCompleted

onError

onNext

hasObservers