com.jakewharton.rxrelay2

Class BehaviorRelay<T>

java.lang.Object

io.reactivex.Observable<T>

com.jakewharton.rxrelay2.Relay<T>

com.jakewharton.rxrelay2.BehaviorRelay<T>

All Implemented Interfaces:

io.reactivex.functions.Consumer<T>, io.reactivex.ObservableSource<T>

public final class BehaviorRelay<T>
extends Relay<T>

Relay 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.
  BehaviorRelay<Object> subject = BehaviorRelay.create("default");
  subject.subscribe(observer);
  subject.accept("one");
  subject.accept("two");
  subject.accept("three");

  // observer will receive the "one", "two" and "three" events, but not "zero"
  BehaviorRelay<Object> subject = BehaviorRelay.create("default");
  subject.accept("zero");
  subject.accept("one");
  subject.subscribe(observer);
  subject.accept("two");
  subject.accept("three");
   

Method Summary

Modifier and Type	Method and Description
void	accept(T value)
static <T> BehaviorRelay<T>	create() Creates a BehaviorRelay without a default item.
static <T> BehaviorRelay<T>	createDefault(T defaultValue) Creates a BehaviorRelay that emits the last item it observed and all subsequent items to each Observer that subscribes to it.
T	getValue() Returns a single value the Relay currently has or null if no such value exists.
Object[]	getValues() Returns an Object array containing snapshot all values of the Relay.
T[]	getValues(T[] array) Returns a typed array containing a snapshot of all values of the Relay.
boolean	hasObservers() Returns true if the subject has any Observers.
boolean	hasValue() Returns true if the subject has any value.
protected void	subscribeActual(io.reactivex.Observer<? super T> observer)

Methods inherited from class com.jakewharton.rxrelay2.Relay

toSerialized

Methods inherited from class io.reactivex.Observable

all, amb, ambArray, ambWith, any, blockingFirst, blockingFirst, blockingForEach, blockingIterable, blockingIterable, blockingLast, blockingLast, blockingLatest, blockingMostRecent, blockingNext, blockingSingle, blockingSingle, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, bufferSize, cache, cacheWithInitialCapacity, cast, collect, collectInto, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatestDelayError, combineLatestDelayError, combineLatestDelayError, combineLatestDelayError, combineLatestDelayError, compose, concat, concat, concat, concat, concat, concat, concatArray, concatArrayDelayError, concatArrayEager, concatArrayEager, concatDelayError, concatDelayError, concatDelayError, concatEager, concatEager, concatEager, concatEager, concatMap, concatMap, concatMapDelayError, concatMapDelayError, concatMapEager, concatMapEager, concatMapEagerDelayError, concatMapEagerDelayError, concatMapIterable, concatMapIterable, concatWith, contains, count, create, debounce, debounce, debounce, defaultIfEmpty, defer, delay, delay, delay, delay, delay, delay, delaySubscription, delaySubscription, delaySubscription, dematerialize, distinct, distinct, distinct, distinctUntilChanged, distinctUntilChanged, distinctUntilChanged, doAfterNext, doAfterTerminate, doFinally, doOnComplete, doOnDispose, doOnEach, doOnEach, doOnError, doOnLifecycle, doOnNext, doOnSubscribe, doOnTerminate, elementAt, elementAt, elementAtOrError, empty, error, error, filter, first, firstElement, firstOrError, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMapCompletable, flatMapCompletable, flatMapIterable, flatMapIterable, flatMapMaybe, flatMapMaybe, flatMapSingle, flatMapSingle, forEach, forEachWhile, forEachWhile, forEachWhile, fromArray, fromCallable, fromFuture, fromFuture, fromFuture, fromFuture, fromIterable, fromPublisher, generate, generate, generate, generate, generate, groupBy, groupBy, groupBy, groupBy, groupBy, groupJoin, hide, ignoreElements, interval, interval, interval, interval, intervalRange, intervalRange, isEmpty, join, just, just, just, just, just, just, just, just, just, just, last, lastElement, lastOrError, lift, map, materialize, merge, merge, merge, merge, merge, merge, merge, merge, mergeArray, mergeArray, mergeArrayDelayError, mergeArrayDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, never, observeOn, observeOn, observeOn, ofType, onErrorResumeNext, onErrorResumeNext, onErrorReturn, onErrorReturnItem, onExceptionResumeNext, onTerminateDetach, publish, publish, range, rangeLong, reduce, reduce, reduceWith, repeat, repeat, repeatUntil, repeatWhen, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, retry, retry, retry, retry, retry, retryUntil, retryWhen, safeSubscribe, sample, sample, sample, scan, scan, scanWith, sequenceEqual, sequenceEqual, sequenceEqual, sequenceEqual, serialize, share, single, singleElement, singleOrError, skip, skip, skip, skipLast, skipLast, skipLast, skipLast, skipLast, skipLast, skipUntil, skipWhile, sorted, sorted, startWith, startWith, startWith, startWithArray, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchIfEmpty, switchMap, switchMap, switchMapDelayError, switchMapDelayError, switchOnNext, switchOnNext, switchOnNextDelayError, switchOnNextDelayError, take, take, take, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeUntil, takeUntil, takeWhile, test, test, throttleFirst, throttleFirst, throttleLast, throttleLast, throttleWithTimeout, throttleWithTimeout, timeInterval, timeInterval, timeInterval, timeInterval, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timer, timer, timestamp, timestamp, timestamp, timestamp, to, toFlowable, toFuture, toList, toList, toList, toMap, toMap, toMap, toMultimap, toMultimap, toMultimap, toMultimap, toSortedList, toSortedList, toSortedList, toSortedList, unsafeCreate, unsubscribeOn, using, using, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, withLatestFrom, withLatestFrom, withLatestFrom, withLatestFrom, withLatestFrom, withLatestFrom, wrap, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipArray, zipIterable, zipWith, zipWith, zipWith, zipWith

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public static <T> BehaviorRelay<T> create()

Creates a BehaviorRelay without a default item.

createDefault

public static <T> BehaviorRelay<T> createDefault(T defaultValue)

Creates a BehaviorRelay that emits the last item it observed and all subsequent items to each Observer that subscribes to it.

Parameters:

defaultValue - the item that will be emitted first to any Observer as long as the BehaviorRelay has not yet observed any items from its source Observable

subscribeActual

protected void subscribeActual(io.reactivex.Observer<? super T> observer)

Specified by:

subscribeActual in class io.reactivex.Observable<T>

accept

public void accept(T value)

Description copied from class: Relay

Specified by:

accept in interface io.reactivex.functions.Consumer<T>

Specified by:

accept in class Relay<T>

hasObservers

public boolean hasObservers()

Description copied from class: Relay

Returns true if the subject has any Observers.

The method is thread-safe.

Specified by:

hasObservers in class Relay<T>

getValue

public T getValue()

Returns a single value the Relay currently has or null if no such value exists.

The method is thread-safe.

getValues

public Object[] getValues()

Returns an Object array containing snapshot all values of the Relay.

The method is thread-safe.

getValues

public T[] getValues(T[] array)

Returns a typed array containing a snapshot of all values of the Relay.

The method follows the conventions of Collection.toArray by setting the array element after the last value to null (if the capacity permits).

The method is thread-safe.

Parameters:

array - the target array to copy values into if it fits

hasValue

public boolean hasValue()

Returns true if the subject has any value.

The method is thread-safe.

Returns:

true if the subject has any value