hu.akarnokd.rxjava2

Interface NbpObservable.NbpOperator<Downstream,Upstream>

All Superinterfaces:

Function<NbpObservable.NbpSubscriber<? super Downstream>,NbpObservable.NbpSubscriber<? super Upstream>>

All Known Implementing Classes:

NbpOperatorAll, NbpOperatorAny, NbpOperatorBuffer, NbpOperatorBufferBoundary, NbpOperatorBufferBoundarySupplier, NbpOperatorBufferExactBoundary, NbpOperatorBufferTimed, NbpOperatorCollect, NbpOperatorConcatMap, NbpOperatorCount, NbpOperatorDebounce, NbpOperatorDebounceTimed, NbpOperatorDelay, NbpOperatorDematerialize, NbpOperatorDistinct, NbpOperatorDoOnEach, NbpOperatorElementAt, NbpOperatorFilter, NbpOperatorFlatMap, NbpOperatorGroupBy, NbpOperatorIgnoreElements, NbpOperatorMap, NbpOperatorMapNotification, NbpOperatorMaterialize, NbpOperatorObserveOn, NbpOperatorOnErrorNext, NbpOperatorOnErrorReturn, NbpOperatorSampleTimed, NbpOperatorSampleWithObservable, NbpOperatorScan, NbpOperatorScanSeed, NbpOperatorSingle, NbpOperatorSkip, NbpOperatorSkipLast, NbpOperatorSkipLastTimed, NbpOperatorSkipUntil, NbpOperatorSkipWhile, NbpOperatorSwitchIfEmpty, NbpOperatorSwitchMap, NbpOperatorTake, NbpOperatorTakeLast, NbpOperatorTakeLastOne, NbpOperatorTakeLastTimed, NbpOperatorTakeUntil, NbpOperatorTakeUntilPredicate, NbpOperatorTakeWhile, NbpOperatorThrottleFirstTimed, NbpOperatorTimeInterval, NbpOperatorTimeout, NbpOperatorTimeoutTimed, NbpOperatorToList, NbpOperatorUnsubscribeOn, NbpOperatorWindow, NbpOperatorWindowBoundary, NbpOperatorWindowBoundarySelector, NbpOperatorWindowBoundarySupplier, NbpOperatorWindowTimed, NbpOperatorWithLatestFrom

Enclosing class:

NbpObservable<T>

public static interface NbpObservable.NbpOperator<Downstream,Upstream>
extends Function<NbpObservable.NbpSubscriber<? super Downstream>,NbpObservable.NbpSubscriber<? super Upstream>>

Method Summary

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

apply