hu.akarnokd.rxjava2.subjects

Class Subject<T,R>

java.lang.Object

hu.akarnokd.rxjava2.Observable<R>

hu.akarnokd.rxjava2.subjects.Subject<T,R>

Type Parameters:

T - the source value type

R - the emission value type

All Implemented Interfaces:

org.reactivestreams.Processor<T,R>, org.reactivestreams.Publisher<R>, org.reactivestreams.Subscriber<T>

Direct Known Subclasses:

AsyncSubject, BehaviorSubject, PublishSubject, ReplaySubject, UnicastSubject

public abstract class Subject<T,R>
extends Observable<R>
implements org.reactivestreams.Processor<T,R>

Represents a Subscriber and an Observable (Publisher) at the same time, allowing multicasting events from a single source to multiple child Subscribers.

All methods except the onSubscribe, onNext, onError and onComplete are thread-safe. Use toSerialized() to make these methods thread-safe as well.

Nested Class Summary

Nested classes/interfaces inherited from class hu.akarnokd.rxjava2.Observable

Observable.Operator<Downstream,Upstream>, Observable.Transformer<T,R>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Subject(org.reactivestreams.Publisher<R> onSubscribe)

Method Summary

Modifier and Type	Method and Description
java.lang.Throwable	getThrowable() Returns the error that caused the Subject to terminate or null if the Subject hasn't terminated yet.
R	getValue() Returns a single value the Subject currently has or null if no such value exists.
java.lang.Object[]	getValues() Returns an Object array containing snapshot all values of the Subject.
R[]	getValues(R[] array) Returns a typed array containing a snapshot of all values of the Subject.
boolean	hasComplete() Returns true if the subject has reached a terminal state through a complete event.
abstract boolean	hasSubscribers() Returns true if the subject has subscribers.
boolean	hasThrowable() Returns true if the subject has reached a terminal state through an error event.
boolean	hasValue() Returns true if the subject has any value.
Subject<T,R>	toSerialized() Wraps this Subject and serializes the calls to the onSubscribe, onNext, onError and onComplete methods, making them thread-safe.

Methods inherited from class hu.akarnokd.rxjava2.Observable

all, amb, amb, ambWith, any, asObservable, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, bufferSize, cache, cache, cast, collect, collectInto, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, compose, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concatArray, concatArray, concatMap, concatMap, concatMapIterable, concatMapIterable, concatWith, contains, count, create, debounce, debounce, debounce, defaultIfEmpty, defer, delay, delay, delay, delay, delay, delay, delaySubscription, delaySubscription, delaySubscription, delaySubscription, dematerialize, distinct, distinct, distinct, distinctUntilChanged, distinctUntilChanged, doOnCancel, doOnComplete, doOnEach, doOnEach, doOnError, doOnLifecycle, doOnNext, doOnRequest, doOnSubscribe, doOnTerminate, elementAt, elementAt, empty, endWith, endWith, endWith, endWithArray, error, error, filter, finallyDo, first, first, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMapIterable, flatMapIterable, flatMapIterable, forEach, forEachWhile, forEachWhile, forEachWhile, fromArray, fromCallable, fromFuture, fromFuture, fromFuture, fromFuture, fromIterable, fromPublisher, generate, generate, generate, generate, generate, groupBy, groupBy, groupBy, groupBy, groupBy, ignoreElements, interval, interval, interval, interval, intervalRange, intervalRange, isEmpty, just, just, just, just, just, just, just, just, just, last, last, lift, map, materialize, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, nest, never, observeOn, observeOn, observeOn, ofType, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureDrop, onBackpressureDrop, onBackpressureLatest, onErrorResumeNext, onErrorResumeNext, onErrorReturn, onErrorReturnValue, onExceptionResumeNext, publish, publish, publish, publish, range, 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, single, skip, skip, skipLast, skipLast, skipLast, skipLast, skipLast, skipLast, skipUntil, skipWhile, startWith, startWith, startWith, startWithArray, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeOn, switchIfEmpty, switchMap, switchMap, switchOnNext, switchOnNext, take, take, takeFirst, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeUntil, takeUntil, takeWhile, 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, toBlocking, toList, toList, toList, toMap, toMap, toMap, toMultimap, toMultimap, toMultimap, toMultimap, toNbpObservable, toSingle, toSortedList, toSortedList, toSortedList, toSortedList, unsafeSubscribe, unsubscribeOn, using, using, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, withLatestFrom, 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

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext, onSubscribe

Methods inherited from interface org.reactivestreams.Publisher

subscribe

Constructor Detail

Subject

protected Subject(org.reactivestreams.Publisher<R> onSubscribe)

Method Detail

hasSubscribers

public abstract boolean hasSubscribers()

Returns true if the subject has subscribers.

The method is thread-safe.

Returns:

true if the subject has subscribers

hasThrowable

public boolean hasThrowable()

Returns true if the subject has reached a terminal state through an error event.

The method is thread-safe.

Returns:

true if the subject has reached a terminal state through an error event

See Also:

getThrowable(), hasComplete()

hasComplete

public boolean hasComplete()

Returns true if the subject has reached a terminal state through a complete event.

The method is thread-safe.

Returns:

true if the subject has reached a terminal state through a complete event

See Also:

hasThrowable()

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

getThrowable

public java.lang.Throwable getThrowable()

Returns the error that caused the Subject to terminate or null if the Subject hasn't terminated yet.

The method is thread-safe.

Returns:

the error that caused the Subject to terminate or null if the Subject hasn't terminated yet

getValue

public R getValue()

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

The method is thread-safe.

Returns:

a single value the Subject currently has or null if no such value exists

toSerialized

public final Subject<T,R> toSerialized()

Wraps this Subject and serializes the calls to the onSubscribe, onNext, onError and onComplete methods, making them thread-safe.

The method is thread-safe.

Returns:

the wrapped and serialized subject

getValues

public java.lang.Object[] getValues()

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

The method is thread-safe.

Returns:

the array containing the snapshot of all values of the Subject

getValues

public R[] getValues(R[] array)

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

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

Returns:

the given array if the values fit into it or a new array containing all values