T - the type of item observed by and emitted by the subject
public final class TestSubject<T> extends Subject<T ,T>
TestScheduler and allows you to precisely time emissions and notifications to the Subject's subscribers using relative virtual time controlled by the
TestScheduler.
Observable.OnSubscribe <T>, Observable.Operator <R,T>, Observable.Transformer <T,R> | Modifier | Constructor and Description |
|---|---|
protected |
TestSubject(Observable
|
| Modifier and Type | Method and Description |
|---|---|
static <T> TestSubject |
create(TestScheduler
Creates and returns a new
TestSubject.
|
boolean |
hasObservers()
|
void |
onCompleted()
Schedule a call to
onCompleted at relative time of "now()" on TestScheduler.
|
void |
onCompleted(long timeInMilliseconds)
Schedule a call to
onCompleted relative to "now()" +n milliseconds in the future.
|
void |
onError(Throwable
Schedule a call to
onError at relative time of "now()" on TestScheduler.
|
void |
onError(Throwable
Schedule a call to
onError relative to "now()" +n milliseconds in the future.
|
void |
onNext(T v)
Schedule a call to
onNext at relative time of "now()" on TestScheduler.
|
void |
onNext(T v, long timeInMilliseconds)
Schedule a call to
onNext relative to "now()" +n milliseconds in the future.
|
toSerializedall, 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, create, 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, zipWithprotected TestSubject(Observable.OnSubscribe <T> onSubscribe, rx .subjects .SubjectSubscriptionManager <T> state, TestScheduler scheduler)
public static <T> TestSubject<T> create(TestScheduler scheduler)
TestSubject.
T - the value type
scheduler - a
TestScheduler on which to operate this Subject
TestSubject
public void onCompleted()
onCompleted at relative time of "now()" on TestScheduler.
public void onCompleted(long timeInMilliseconds)
onCompleted relative to "now()" +n milliseconds in the future.
timeInMilliseconds - the number of milliseconds in the future relative to "now()" at which to call
onCompleted
public void onError(Throwablee)
onError at relative time of "now()" on TestScheduler.
e - the exception encountered by the Observable
public void onError(Throwablee, long timeInMilliseconds)
onError relative to "now()" +n milliseconds in the future.
e - the
Throwable to pass to the
onError method
timeInMilliseconds - the number of milliseconds in the future relative to "now()" at which to call
onError
public void onNext(T v)
onNext at relative time of "now()" on TestScheduler.
v - the item emitted by the Observable
public void onNext(T v, long timeInMilliseconds)
onNext relative to "now()" +n milliseconds in the future.
v - the item to emit
timeInMilliseconds - the number of milliseconds in the future relative to "now()" at which to call
onNext
public boolean hasObservers()
Subject
hasObservers in class
Subject<T,T>