T - public class Subject<T> extends Observable<T> implements Observer<T>
Observable.Accumulator<T>, Observable.Comparator<T>, Observable.ElementSelector<T,R>, Observable.Factory<T>, Observable.IndexedPredicate<T>, Observable.IndexedResultSelector<T,R>, Observable.IndexedSourcePredicate<T>, Observable.KeyComparator<K>, Observable.KeySelector<T,K>, Observable.OperatorFunction<T,R>, Observable.Predicate<T>, Observable.Projector<T,R>, Observable.ResultSelector<T,I,R>, Observable.Scanner<R,T>, Observable.Selector<T>, Observable.SubjectFactory<T>, Observable.TransformingAccumulator<R,T>| Constructor and Description |
|---|
Subject() |
| Modifier and Type | Method and Description |
|---|---|
Observable<T> |
asObservable() |
void |
complete() |
void |
error(java.lang.Object error) |
void |
next(T value) |
_catch, _do, _do, _do, _finally, _if, _if, _if, _switch, _throw, _throw, audit, auditTime, buffer, bufferCount, bufferCount, bufferTime, bufferTime, bufferTime, bufferToggle, bufferWhen, combineAll, combineAll, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, concat, concat, concat, concat, concat, concat, concatAll, concatMap, concatMap, concatMapTo, count, count, count, create, debounce, debounceTime, defaultIfEmpty, defer, delay, delayWhen, delayWhen, distinct, distinct, distinct, distinctUntilChanged, distinctUntilChanged, distinctUntilChanged, elementAt, elementAt, empty, every, every, exhaust, exhaustMap, exhaustMap, expand, expand, expand, filter, filter, find, find, findIndex, first, first, first, first, first, first, flapMap, flatMap, flatMap, flatMap, flatMap, from, fromEvent, fromEvent, groupBy, groupBy, ignoreElements, interval, interval, isEmpty, last, last, last, last, last, last, let, map, mapTo, max, max, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, mergeAll, mergeAll, mergeMap, mergeMap, mergeMap, mergeMap, mergeMapTo, mergeMapTo, mergeMapTo, mergeMapTo, mergeScan, mergeScan, min, min, multicast, multicast, multicast, multicast, multicast, multicast, multicast, multicast, multicast, never, observeOn, observeOn, of, onErrorResumeNext, onErrorResumeNext, onErrorResumeNext, onErrorResumeNext, onErrorResumeNext, onErrorResumeNext, pairs, pairwise, partition, pluck, publish, publish, publish, publishBehavior, publishLast, publishReplay, publishReplay, publishReplay, publishReplay, publishReplay, publishReplay, race, range, range, reduce, reduce, reduce, reduce, reduceArray, reduceArray, repeat, repeat, repeatWhen, retry, retry, retryWhen, sample, sampleTime, sampleTime, scan, scan, scan, scan, scanArray, scanArray, sequenceEqual, share, single, skip, skipLast, skipUntil, skipWhile, skipWhile, startWith, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeOn, switchMap, switchMap, switchMapTo, take, takeLast, takeUntil, takeWhile, throttle, throttleTime, throttleTime, timeInterval, timeInterval, timeout, timeout, timeoutWith, timeoutWith, timer, timer, timer, timestamp, timestamp, toArray, window, windowCount, windowCount, windowTime, windowTime, windowTime, windowTime, windowTime, windowTime, windowToggle, windowWhen, withLatestFrom, withLatestFrom, withLatestFrom, withLatestFrom, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipAll, zipAllpublic Observable<T> asObservable()