hu.akarnokd.rxjava2

Interface Observable.Operator<Downstream,Upstream>

Type Parameters:

Downstream - the value type of the downstream

Upstream - the value type of the upstream

All Superinterfaces:

Function<org.reactivestreams.Subscriber<? super Downstream>,org.reactivestreams.Subscriber<? super Upstream>>

All Known Implementing Classes:

OperatorAll, OperatorAny, OperatorBuffer, OperatorBufferBoundary, OperatorBufferBoundarySupplier, OperatorBufferExactBoundary, OperatorBufferTimed, OperatorCollect, OperatorConcatMap, OperatorCount, OperatorDebounce, OperatorDebounceTimed, OperatorDelay, OperatorDematerialize, OperatorDistinct, OperatorDoOnEach, OperatorElementAt, OperatorFilter, OperatorFlatMap, OperatorGroupBy, OperatorIgnoreElements, OperatorMap, OperatorMapNotification, OperatorMaterialize, OperatorObserveOn, OperatorOnBackpressureBuffer, OperatorOnBackpressureDrop, OperatorOnBackpressureLatest, OperatorOnErrorNext, OperatorOnErrorReturn, OperatorSamplePublisher, OperatorSampleTimed, OperatorScan, OperatorScanSeed, OperatorSingle, OperatorSkip, OperatorSkipLast, OperatorSkipLastTimed, OperatorSkipUntil, OperatorSkipWhile, OperatorSwitchIfEmpty, OperatorSwitchMap, OperatorTake, OperatorTakeLast, OperatorTakeLastOne, OperatorTakeLastTimed, OperatorTakeUntil, OperatorTakeUntilPredicate, OperatorTakeWhile, OperatorThrottleFirstTimed, OperatorTimeInterval, OperatorTimeout, OperatorTimeoutTimed, OperatorToList, OperatorUnsubscribeOn, OperatorWindow, OperatorWindowBoundary, OperatorWindowBoundarySelector, OperatorWindowBoundarySupplier, OperatorWindowTimed, OperatorWithLatestFrom

Enclosing class:

Observable<T>

public static interface Observable.Operator<Downstream,Upstream>
extends Function<org.reactivestreams.Subscriber<? super Downstream>,org.reactivestreams.Subscriber<? super Upstream>>

Interface to map/wrap a downstream subscriber to an upstream subscriber.

Method Summary

Methods inherited from interface hu.akarnokd.rxjava2.functions.Function

apply