Package rx

Interface Observable.Operator<R,T>

Type Parameters:
R - the downstream's value type (output)
T - the upstream's value type (input)
All Superinterfaces:
Func1<Subscriber<? super R>,Subscriber<? super T>>, Function
All Known Implementing Classes:
OperatorAll, OperatorAny, OperatorAsObservable, OperatorBufferWithSingleObservable, OperatorBufferWithSize, OperatorBufferWithStartEndObservable, OperatorBufferWithTime, OperatorCast, OperatorDebounceWithSelector, OperatorDebounceWithTime, OperatorDelay, OperatorDelayWithSelector, OperatorDematerialize, OperatorDistinct, OperatorDistinctUntilChanged, OperatorDoAfterTerminate, OperatorDoOnEach, OperatorDoOnRequest, OperatorDoOnSubscribe, OperatorDoOnUnsubscribe, OperatorEagerConcatMap, OperatorElementAt, OperatorGroupBy, OperatorIgnoreElements, OperatorMapNotification, OperatorMapPair, OperatorMaterialize, OperatorMerge, OperatorObserveOn, OperatorOnBackpressureBuffer, OperatorOnBackpressureDrop, OperatorOnBackpressureLatest, OperatorOnErrorResumeNextViaFunction, OperatorRetryWithPredicate, OperatorSampleWithObservable, OperatorSampleWithTime, OperatorScan, OperatorSerialize, OperatorSingle, OperatorSkip, OperatorSkipLast, OperatorSkipLastTimed, OperatorSkipTimed, OperatorSkipUntil, OperatorSkipWhile, OperatorSwitch, OperatorSwitchIfEmpty, OperatorTake, OperatorTakeLast, OperatorTakeLastTimed, OperatorTakeTimed, OperatorTakeUntil, OperatorTakeUntilPredicate, OperatorTakeWhile, OperatorThrottleFirst, OperatorTimeInterval, OperatorTimeout, OperatorTimeoutBase, OperatorTimeoutWithSelector, OperatorTimestamp, OperatorToMap, OperatorToMultimap, OperatorToObservableList, OperatorToObservableSortedList, OperatorUnsubscribeOn, OperatorWindowWithObservable, OperatorWindowWithObservableFactory, OperatorWindowWithSize, OperatorWindowWithStartEndObservable, OperatorWindowWithTime, OperatorWithLatestFrom, OperatorZip, OperatorZipIterable
Enclosing class:
Observable<T>

public static interface Observable.Operator<R,T> extends Func1<Subscriber<? super R>,Subscriber<? super T>>
Operator function for lifting into an Observable.
  • Method Summary

    Methods inherited from interface rx.functions.Func1

    call