- accept(T1, T2) - Method in interface hu.akarnokd.rxjava2.functions.BiConsumer
-
- accept(T) - Method in interface hu.akarnokd.rxjava2.functions.Consumer
-
- accept(long) - Method in interface hu.akarnokd.rxjava2.functions.LongConsumer
-
- accept(Completable.CompletableSubscriber) - Method in class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeConcat
-
- accept(Completable.CompletableSubscriber) - Method in class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeConcatArray
-
- accept(Completable.CompletableSubscriber) - Method in class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeConcatIterable
-
- accept(Completable.CompletableSubscriber) - Method in class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeMerge
-
- accept(Completable.CompletableSubscriber) - Method in class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeMergeArray
-
- accept(Completable.CompletableSubscriber) - Method in class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeMergeDelayErrorArray
-
- accept(Completable.CompletableSubscriber) - Method in class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeMergeDelayErrorIterable
-
- accept(Completable.CompletableSubscriber) - Method in class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeMergeIterable
-
- accept(Completable.CompletableSubscriber) - Method in class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeTimeout
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeAmb
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeArraySource
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeAutoConnect
-
- accept(NbpObservable.NbpSubscriber<? super R>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeCombineLatest
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeDefer
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeDelaySubscriptionOther
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeErrorSource
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeFutureSource
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeGenerate
-
- accept(NbpObservable.NbpSubscriber<? super Long>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeIntervalRangeSource
-
- accept(NbpObservable.NbpSubscriber<? super Long>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeIntervalSource
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeIterableSource
-
- accept(NbpObservable.NbpSubscriber<? super R>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeLift
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeRedo
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeRefCount
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeRepeat
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeRepeatUntil
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeRetryBiPredicate
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeRetryPredicate
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeScalarAsyncSource
-
- accept(NbpObservable.NbpSubscriber<? super Boolean>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeSequenceEqual
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeSubscribeOn
-
- accept(NbpObservable.NbpSubscriber<? super Long>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeTimerOnceSource
-
- accept(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeUsing
-
- accept(NbpObservable.NbpSubscriber<? super R>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeZip
-
- accept(NbpObservable.NbpSubscriber<? super V>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeZipIterable
-
- accept(NbpObservable.NbpSubscriber<? super U>, T) - Method in interface hu.akarnokd.rxjava2.internal.util.NbpQueueDrain
-
Accept the value and return true if forwarded.
- accept(Object, Subscriber<? super T>) - Static method in enum hu.akarnokd.rxjava2.internal.util.NotificationLite
-
Calls the appropriate Subscriber method based on the type of the notification.
- accept(Object, NbpObservable.NbpSubscriber<? super T>) - Static method in enum hu.akarnokd.rxjava2.internal.util.NotificationLite
-
Calls the appropriate NbpSubscriber method based on the type of the notification.
- accept(Subscriber<? super U>, T) - Method in interface hu.akarnokd.rxjava2.internal.util.QueueDrain
-
Accept the value and return true if forwarded.
- acceptFull(Object, Subscriber<? super T>) - Static method in enum hu.akarnokd.rxjava2.internal.util.NotificationLite
-
Calls the appropriate Subscriber method based on the type of the notification.
- acceptFull(Object, NbpObservable.NbpSubscriber<? super T>) - Static method in enum hu.akarnokd.rxjava2.internal.util.NotificationLite
-
Calls the appropriate NbpSubscriber method based on the type of the notification.
- actual - Variable in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpQueueDrainSubscriber
-
- actual - Variable in class hu.akarnokd.rxjava2.internal.subscribers.QueueDrainSubscriber
-
- add(Disposable) - Method in class hu.akarnokd.rxjava2.disposables.CompositeDisposable
-
- add(T) - Method in interface hu.akarnokd.rxjava2.internal.disposables.CompositeResource
-
- add(T) - Method in class hu.akarnokd.rxjava2.internal.disposables.ListCompositeResource
-
Adds a new resource to this composite or disposes it if the composite has been disposed.
- add(T) - Method in class hu.akarnokd.rxjava2.internal.disposables.SetCompositeResource
-
Adds a new resource to this composite or disposes it if the composite has been disposed.
- add(T) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue
-
- add(T) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- add(T) - Method in class hu.akarnokd.rxjava2.internal.util.AppendOnlyLinkedArrayList
-
Append a non-null value to the list.
- add(AtomicLong, long) - Static method in enum hu.akarnokd.rxjava2.internal.util.BackpressureHelper
-
Atomically adds the positive value n to the requested value in the AtomicLong and
caps the result at Long.MAX_VALUE and returns the previous value.
- add(AtomicLongFieldUpdater<T>, T, long) - Static method in enum hu.akarnokd.rxjava2.internal.util.BackpressureHelper
-
Atomically adds the positive value n to the value in the instance through the field updater and
caps the result at Long.MAX_VALUE and returns the previous value.
- add(Object) - Method in class hu.akarnokd.rxjava2.internal.util.LinkedArrayList
-
Adds a new element to this list.
- add(T) - Method in class hu.akarnokd.rxjava2.internal.util.OpenHashSet
-
- add(AtomicReferenceFieldUpdater<T, U[]>, T, U, U[], IntFunction<U[]>) - Static method in enum hu.akarnokd.rxjava2.internal.util.TerminalAtomicsHelper
-
Atomically replaces the array in instance with a new array that contains the newValue as well
or returns false if the instance holds the terminalValue.
- add(AtomicReference<U[]>, U, U[], IntFunction<U[]>) - Static method in enum hu.akarnokd.rxjava2.internal.util.TerminalAtomicsHelper
-
Atomically replaces the array in instance with a new array that contains the newValue as well
or returns false if the instance holds the terminalValue.
- add(Disposable) - Method in class hu.akarnokd.rxjava2.subscribers.AsyncObserver
-
Adds a resource to this AsyncObserver.
- add(Disposable) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpAsyncObserver
-
Adds a resource to this AsyncObserver.
- addAll(Collection<? extends T>) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue
-
- addAll(Collection<? extends T>) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- addCap(long, long) - Static method in enum hu.akarnokd.rxjava2.internal.util.BackpressureHelper
-
Adds two long values and caps the sum at Long.MAX_VALUE.
- advanceTimeBy(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.schedulers.TestScheduler
-
Moves the Scheduler's clock forward by a specified amount of time.
- advanceTimeTo(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.schedulers.TestScheduler
-
Moves the Scheduler's clock to a particular moment in time.
- all(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- all(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- alwaysFalse() - Static method in enum hu.akarnokd.rxjava2.internal.functions.Functions
-
- alwaysTrue() - Static method in enum hu.akarnokd.rxjava2.internal.functions.Functions
-
- amb(Completable...) - Static method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable which terminates as soon as one of the source Completables
terminates (normally or with an error) and cancels all other Completables.
- amb(Iterable<? extends Completable>) - Static method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable which terminates as soon as one of the source Completables
terminates (normally or with an error) and cancels all other Completables.
- amb(Iterable<? extends NbpObservable<? extends T>>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- amb(NbpObservable<? extends T>...) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- amb(Iterable<? extends Publisher<? extends T>>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- amb(Publisher<? extends T>...) - Static method in class hu.akarnokd.rxjava2.Observable
-
- amb(Iterable<? extends Single<? extends T>>) - Static method in class hu.akarnokd.rxjava2.Single
-
- amb(Single<? extends T>...) - Static method in class hu.akarnokd.rxjava2.Single
-
- ambWith(Completable) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable that emits the a terminated event of either this Completable
or the other Completable whichever fires first.
- ambWith(NbpObservable<? extends T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- ambWith(Publisher<? extends T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- ambWith(Single<? extends T>) - Method in class hu.akarnokd.rxjava2.Single
-
- any(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- any(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- AppendOnlyLinkedArrayList<T> - Class in hu.akarnokd.rxjava2.internal.util
-
A linked-array-list implementation that only supports appending and consumption.
- AppendOnlyLinkedArrayList(int) - Constructor for class hu.akarnokd.rxjava2.internal.util.AppendOnlyLinkedArrayList
-
Constructs an empty list with a per-link capacity
- apply(T1, T2) - Method in interface hu.akarnokd.rxjava2.functions.BiFunction
-
- apply(T) - Method in interface hu.akarnokd.rxjava2.functions.Function
-
- apply(T1, T2, T3) - Method in interface hu.akarnokd.rxjava2.functions.Function3
-
- apply(T1, T2, T3, T4) - Method in interface hu.akarnokd.rxjava2.functions.Function4
-
- apply(T1, T2, T3, T4, T5) - Method in interface hu.akarnokd.rxjava2.functions.Function5
-
- apply(T1, T2, T3, T4, T5, T6) - Method in interface hu.akarnokd.rxjava2.functions.Function6
-
- apply(T1, T2, T3, T4, T5, T6, T7) - Method in interface hu.akarnokd.rxjava2.functions.Function7
-
- apply(T1, T2, T3, T4, T5, T6, T7, T8) - Method in interface hu.akarnokd.rxjava2.functions.Function8
-
- apply(T1, T2, T3, T4, T5, T6, T7, T8, T9) - Method in interface hu.akarnokd.rxjava2.functions.Function9
-
- apply(int) - Method in interface hu.akarnokd.rxjava2.functions.IntFunction
-
- apply(NbpObservable.NbpSubscriber<? super Boolean>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorAll
-
- apply(NbpObservable.NbpSubscriber<? super Boolean>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorAny
-
- apply(NbpObservable.NbpSubscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorBuffer
-
- apply(NbpObservable.NbpSubscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorBufferBoundary
-
- apply(NbpObservable.NbpSubscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorBufferBoundarySupplier
-
- apply(NbpObservable.NbpSubscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorBufferExactBoundary
-
- apply(NbpObservable.NbpSubscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorBufferTimed
-
- apply(NbpObservable.NbpSubscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorCollect
-
- apply(NbpObservable.NbpSubscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorConcatMap
-
- apply(NbpObservable.NbpSubscriber<? super Long>) - Method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorCount
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorDebounce
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorDebounceTimed
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorDelay
-
- apply(NbpObservable.NbpSubscriber<? super Object>) - Method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorDematerialize
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorDistinct
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorDoOnEach
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorElementAt
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorFilter
-
- apply(NbpObservable.NbpSubscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorFlatMap
-
- apply(NbpObservable.NbpSubscriber<? super NbpGroupedObservable<K, V>>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorGroupBy
-
- apply(NbpObservable.NbpSubscriber<? super Object>) - Method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorIgnoreElements
-
- apply(NbpObservable.NbpSubscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorMap
-
- apply(NbpObservable.NbpSubscriber<? super NbpObservable<? extends R>>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorMapNotification
-
- apply(NbpObservable.NbpSubscriber<? super Try<Optional<Object>>>) - Method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorMaterialize
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorObserveOn
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorOnErrorNext
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorOnErrorReturn
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSampleTimed
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSampleWithObservable
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorScan
-
- apply(NbpObservable.NbpSubscriber<? super R>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorScanSeed
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSingle
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSkip
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSkipLast
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSkipLastTimed
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSkipUntil
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSkipWhile
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSwitchIfEmpty
-
- apply(NbpObservable.NbpSubscriber<? super R>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSwitchMap
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTake
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTakeLast
-
- apply(NbpObservable.NbpSubscriber<? super Object>) - Method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTakeLastOne
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTakeLastTimed
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTakeUntil
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTakeUntilPredicate
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTakeWhile
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorThrottleFirstTimed
-
- apply(NbpObservable.NbpSubscriber<? super Timed<T>>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTimeInterval
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTimeout
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTimeoutTimed
-
- apply(NbpObservable.NbpSubscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorToList
-
- apply(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorUnsubscribeOn
-
- apply(NbpObservable.NbpSubscriber<? super NbpObservable<T>>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorWindow
-
- apply(NbpObservable.NbpSubscriber<? super NbpObservable<T>>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorWindowBoundary
-
- apply(NbpObservable.NbpSubscriber<? super NbpObservable<T>>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorWindowBoundarySelector
-
- apply(NbpObservable.NbpSubscriber<? super NbpObservable<T>>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorWindowBoundarySupplier
-
- apply(NbpObservable.NbpSubscriber<? super NbpObservable<T>>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorWindowTimed
-
- apply(NbpObservable.NbpSubscriber<? super R>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorWithLatestFrom
-
- apply(Subscriber<? super Boolean>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorAll
-
- apply(Subscriber<? super Boolean>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorAny
-
- apply(Subscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorBuffer
-
- apply(Subscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorBufferBoundary
-
- apply(Subscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorBufferBoundarySupplier
-
- apply(Subscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorBufferExactBoundary
-
- apply(Subscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorBufferTimed
-
- apply(Subscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorCollect
-
- apply(Subscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorConcatMap
-
- apply(Subscriber<? super Long>) - Method in enum hu.akarnokd.rxjava2.internal.operators.OperatorCount
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorDebounce
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorDebounceTimed
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorDelay
-
- apply(Subscriber<? super Object>) - Method in enum hu.akarnokd.rxjava2.internal.operators.OperatorDematerialize
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorDistinct
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorDoOnEach
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorElementAt
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorFilter
-
- apply(Subscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorFlatMap
-
- apply(Subscriber<? super GroupedObservable<K, V>>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorGroupBy
-
- apply(Subscriber<? super Object>) - Method in enum hu.akarnokd.rxjava2.internal.operators.OperatorIgnoreElements
-
- apply(Subscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorMap
-
- apply(Subscriber<? super Publisher<? extends R>>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorMapNotification
-
- apply(Subscriber<? super Try<Optional<Object>>>) - Method in enum hu.akarnokd.rxjava2.internal.operators.OperatorMaterialize
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorObserveOn
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorOnBackpressureBuffer
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorOnBackpressureDrop
-
- apply(Subscriber<? super Object>) - Method in enum hu.akarnokd.rxjava2.internal.operators.OperatorOnBackpressureLatest
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorOnErrorNext
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorOnErrorReturn
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorSamplePublisher
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorSampleTimed
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorScan
-
- apply(Subscriber<? super R>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorScanSeed
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorSingle
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorSkip
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorSkipLast
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorSkipLastTimed
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorSkipUntil
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorSkipWhile
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorSwitchIfEmpty
-
- apply(Subscriber<? super R>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorSwitchMap
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorTake
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorTakeLast
-
- apply(Subscriber<? super Object>) - Method in enum hu.akarnokd.rxjava2.internal.operators.OperatorTakeLastOne
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorTakeLastTimed
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorTakeUntil
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorTakeUntilPredicate
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorTakeWhile
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorThrottleFirstTimed
-
- apply(Subscriber<? super Timed<T>>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorTimeInterval
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorTimeout
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorTimeoutTimed
-
- apply(Subscriber<? super U>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorToList
-
- apply(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorUnsubscribeOn
-
- apply(Subscriber<? super Observable<T>>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorWindow
-
- apply(Subscriber<? super Observable<T>>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorWindowBoundary
-
- apply(Subscriber<? super Observable<T>>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorWindowBoundarySelector
-
- apply(Subscriber<? super Observable<T>>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorWindowBoundarySupplier
-
- apply(Subscriber<? super Observable<T>>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorWindowTimed
-
- apply(Subscriber<? super R>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorWithLatestFrom
-
- apply(Single.SingleSubscriber<? super R>) - Method in class hu.akarnokd.rxjava2.internal.operators.single.SingleOperatorFlatMap
-
- apply(Single.SingleSubscriber<? super R>) - Method in class hu.akarnokd.rxjava2.internal.operators.single.SingleOperatorMap
-
- array() - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeArraySource
-
- array() - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherArraySource
-
- ArrayCompositeResource<T> - Class in hu.akarnokd.rxjava2.internal.disposables
-
A composite resource with a fixed number of slots.
- ArrayCompositeResource(int, Consumer<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.disposables.ArrayCompositeResource
-
- asObservable() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- asObservable() - Method in class hu.akarnokd.rxjava2.Observable
-
- assertComplete() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Assert that this TestSubscriber received exactly one onComplete event.
- assertComplete() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Assert that this TestSubscriber received exactly one onComplete event.
- assertError(Throwable) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Assert that this TestSubscriber received exactly the specified onError event value.
- assertError(Class<? extends Throwable>) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Asserts that this TestSubscriber received exactly one onError event which is an
instance of the specified errorClass class.
- assertError(Throwable) - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Assert that this TestSubscriber received exactly the specified onError event value.
- assertError(Class<? extends Throwable>) - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Asserts that this TestSubscriber received exactly one onError event which is an
instance of the specified errorClass class.
- assertErrorMessage(String) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
- assertErrorMessage(String) - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
- assertNoErrors() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Assert that this TestSubscriber has not received any onError event.
- assertNoErrors() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Assert that this TestSubscriber has not received any onError event.
- assertNotComplete() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Assert that this TestSubscriber has not received any onComplete event.
- assertNotComplete() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Assert that this TestSubscriber has not received any onComplete event.
- assertNotSubscribed() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Assert that the onSubscribe method hasn't been called at all.
- assertNotSubscribed() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Assert that the onSubscribe method hasn't been called at all.
- assertNotTerminated() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Assert that the TestSubscriber has not terminated (i.e., the terminal latch is still non-zero).
- assertNotTerminated() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Assert that the TestSubscriber has not terminated (i.e., the terminal latch is still non-zero).
- assertNoValues() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Assert that this TestSubscriber has not received any onNext events.
- assertNoValues() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Assert that this TestSubscriber has not received any onNext events.
- assertSubscribed() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Assert that the onSubscribe method was called exactly once.
- assertSubscribed() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Assert that the onSubscribe method was called exactly once.
- assertTerminated() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Assert that the TestSubscriber terminated (i.e., the terminal latch reached zero).
- assertTerminated() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Assert that the TestSubscriber terminated (i.e., the terminal latch reached zero).
- assertValue(T) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Assert that this TestSubscriber received exactly one onNext value which is equal to
the given value with respect to Objects.equals.
- assertValue(T) - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Assert that this TestSubscriber received exactly one onNext value which is equal to
the given value with respect to Objects.equals.
- assertValueCount(int) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Assert that this TestSubscriber received the specified number onNext events.
- assertValueCount(int) - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Assert that this TestSubscriber received the specified number onNext events.
- assertValues(T...) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Assert that the TestSubscriber received only the specified values in the specified order.
- assertValues(T...) - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Assert that the TestSubscriber received only the specified values in the specified order.
- assertValueSequence(Iterable<? extends T>) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Assert that the TestSubscriber received only the specified sequence of values in the same order.
- assertValueSequence(Iterable<? extends T>) - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Assert that the TestSubscriber received only the specified sequence of values in the same order.
- assertValueSet(Collection<? extends T>) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Assert that the TestSubscriber received only the specified values in any order.
- assertValueSet(Collection<? extends T>) - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Assert that the TestSubscriber received only the specified values in any order.
- asSingle() - Method in class hu.akarnokd.rxjava2.Single
-
- AsyncObserver<T> - Class in hu.akarnokd.rxjava2.subscribers
-
An abstract Subscriber implementation that allows asynchronous cancellation of its
subscription.
- AsyncObserver() - Constructor for class hu.akarnokd.rxjava2.subscribers.AsyncObserver
-
Constructs an AsyncObserver with resource support.
- AsyncObserver(boolean) - Constructor for class hu.akarnokd.rxjava2.subscribers.AsyncObserver
-
Constructs an AsyncObserver and allows specifying if it should support resources or not.
- AsyncSubject<T> - Class in hu.akarnokd.rxjava2.subjects
-
A Subject that emits the very last value followed by a completion event or the received error to Subscribers.
- AsyncSubject(AsyncSubject.State<T>) - Constructor for class hu.akarnokd.rxjava2.subjects.AsyncSubject
-
- AsyncSubscription - Class in hu.akarnokd.rxjava2.internal.subscriptions
-
A subscription implementation that arbitrates exactly one other Subscription and can
hold a single disposable resource.
- AsyncSubscription() - Constructor for class hu.akarnokd.rxjava2.internal.subscriptions.AsyncSubscription
-
- AsyncSubscription(Disposable) - Constructor for class hu.akarnokd.rxjava2.internal.subscriptions.AsyncSubscription
-
- autoConnect() - Method in class hu.akarnokd.rxjava2.observables.ConnectableObservable
-
Returns an Observable that automatically connects to this ConnectableObservable
when the first Subscriber subscribes.
- autoConnect(int) - Method in class hu.akarnokd.rxjava2.observables.ConnectableObservable
-
Returns an Observable that automatically connects to this ConnectableObservable
when the specified number of Subscribers subscribe to it.
- autoConnect(int, Consumer<? super Disposable>) - Method in class hu.akarnokd.rxjava2.observables.ConnectableObservable
-
Returns an Observable that automatically connects to this ConnectableObservable
when the specified number of Subscribers subscribe to it and calls the
specified callback with the Subscription associated with the established connection.
- autoConnect() - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpConnectableObservable
-
Returns an Observable that automatically connects to this ConnectableObservable
when the first Subscriber subscribes.
- autoConnect(int) - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpConnectableObservable
-
Returns an Observable that automatically connects to this ConnectableObservable
when the specified number of Subscribers subscribe to it.
- autoConnect(int, Consumer<? super Disposable>) - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpConnectableObservable
-
Returns an Observable that automatically connects to this ConnectableObservable
when the specified number of Subscribers subscribe to it and calls the
specified callback with the Subscription associated with the established connection.
- await() - Method in class hu.akarnokd.rxjava2.Completable
-
Subscribes to and awaits the termination of this Completable instance in a blocking manner and
rethrows any exception emitted.
- await(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Completable
-
Subscribes to and awaits the termination of this Completable instance in a blocking manner
with a specific timeout and rethrows any exception emitted within the timeout window.
- await() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Awaits until this TestSubscriber receives an onError or onComplete events.
- await(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Awaits the specified amount of time or until this TestSubscriber
receives an onError or onComplete events, whichever happens first.
- await() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Awaits until this TestSubscriber receives an onError or onComplete events.
- await(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Awaits the specified amount of time or until this TestSubscriber
receives an onError or onComplete events, whichever happens first.
- awaitTerminalEvent() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Waits until the any terminal event has been received by this TestSubscriber
or returns false if the wait has been interrupted.
- awaitTerminalEvent(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Awaits the specified amount of time or until this TestSubscriber
receives an onError or onComplete events, whichever happens first.
- awaitTerminalEvent() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Waits until the any terminal event has been received by this TestSubscriber
or returns false if the wait has been interrupted.
- awaitTerminalEvent(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Awaits the specified amount of time or until this TestSubscriber
receives an onError or onComplete events, whichever happens first.
- cache() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- cache(int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- cache() - Method in class hu.akarnokd.rxjava2.Observable
-
- cache(int) - Method in class hu.akarnokd.rxjava2.Observable
-
- cache() - Method in class hu.akarnokd.rxjava2.Single
-
- CachedObservable<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
An observable which auto-connects to another observable, caches the elements
from that observable but allows terminating the connection and completing the cache.
- cancel(K) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorGroupBy.GroupBySubscriber
-
- cancel() - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorGroupBy.GroupBySubscriber
-
- cancel(K) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorGroupBy.GroupBySubscriber
-
- cancel() - Method in class hu.akarnokd.rxjava2.internal.operators.SubscriberResourceWrapper
-
- cancel() - Method in class hu.akarnokd.rxjava2.internal.subscribers.BlockingSubscriber
-
- cancel() - Method in class hu.akarnokd.rxjava2.internal.subscribers.DisposableSubscriber
-
- cancel() - Method in class hu.akarnokd.rxjava2.internal.subscribers.LambdaSubscriber
-
- cancel() - Method in class hu.akarnokd.rxjava2.internal.subscribers.SubscriptionLambdaSubscriber
-
- cancel() - Method in class hu.akarnokd.rxjava2.internal.subscriptions.AsyncSubscription
-
- cancel() - Method in class hu.akarnokd.rxjava2.internal.subscriptions.BooleanSubscription
-
- cancel() - Method in class hu.akarnokd.rxjava2.internal.subscriptions.DisposableSubscription
-
- cancel() - Method in enum hu.akarnokd.rxjava2.internal.subscriptions.EmptySubscription
-
- cancel() - Method in class hu.akarnokd.rxjava2.internal.subscriptions.FullArbiter
-
- cancel() - Method in class hu.akarnokd.rxjava2.internal.subscriptions.ScalarAsyncSubscription
-
- cancel() - Method in class hu.akarnokd.rxjava2.internal.subscriptions.ScalarSubscription
-
- cancel() - Method in class hu.akarnokd.rxjava2.internal.subscriptions.SubscriptionArbiter
-
- cancel() - Method in class hu.akarnokd.rxjava2.NbpObserver
-
- cancel() - Method in class hu.akarnokd.rxjava2.Observer
-
- cancel() - Method in class hu.akarnokd.rxjava2.subscribers.AsyncObserver
-
Cancels the subscription (if any) and disposes the resources associated with
this AsyncObserver (if any).
- cancel() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpAsyncObserver
-
Cancels the main disposable (if any) and disposes the resources associated with
this AsyncObserver (if any).
- cancel() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
- cancelled - Variable in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpQueueDrainSubscriber
-
- cancelled() - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpQueueDrainSubscriber
-
- cancelled - Variable in class hu.akarnokd.rxjava2.internal.subscribers.QueueDrainSubscriber
-
- cancelled() - Method in class hu.akarnokd.rxjava2.internal.subscribers.QueueDrainSubscriber
-
- cancelled() - Method in interface hu.akarnokd.rxjava2.internal.util.NbpQueueDrain
-
- cancelled() - Method in interface hu.akarnokd.rxjava2.internal.util.QueueDrain
-
- cancelled() - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSubscribers
-
- cancelled() - Static method in class hu.akarnokd.rxjava2.subscribers.Subscribers
-
- CancelledSubscriber - Enum in hu.akarnokd.rxjava2.internal.subscribers
-
A subscriber that cancels the subscription sent to it
and ignores all events (onError is forwarded to RxJavaPlugins though).
- capacityHint() - Method in class hu.akarnokd.rxjava2.internal.util.LinkedArrayList
-
Returns the capacity hint that indicates the capacity of each buffer segment.
- cast(Class<U>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- cast(Class<U>) - Method in class hu.akarnokd.rxjava2.Observable
-
- cast(Class<? extends U>) - Method in class hu.akarnokd.rxjava2.Single
-
- checkTerminated(boolean, boolean, Subscriber<?>, boolean, Queue<?>, QueueDrain<T, U>) - Static method in enum hu.akarnokd.rxjava2.internal.util.QueueDrainHelper
-
- checkTerminated(boolean, boolean, NbpObservable.NbpSubscriber<?>, boolean, Queue<?>, Disposable, NbpQueueDrain<T, U>) - Static method in enum hu.akarnokd.rxjava2.internal.util.QueueDrainHelper
-
- clear() - Method in class hu.akarnokd.rxjava2.disposables.CompositeDisposable
-
- clear() - Method in class hu.akarnokd.rxjava2.internal.disposables.SetCompositeResource
-
- clear() - Method in class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue
-
- clear() - Method in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- clear(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.internal.util.OpenHashSet
-
- collect(Supplier<? extends U>, BiConsumer<? super U, ? super T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- collect(Supplier<? extends U>, BiConsumer<? super U, ? super T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- collectErrors(Queue<Throwable>) - Static method in class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeMerge
-
Collects the Throwables from the queue, adding subsequent Throwables as suppressed to
the first Throwable and returns it.
- collectInto(U, BiConsumer<? super U, ? super T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- collectInto(U, BiConsumer<? super U, ? super T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Function<? super Object[], ? extends R>, boolean, int, NbpObservable<? extends T>...) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(Iterable<? extends NbpObservable<? extends T>>, Function<? super Object[], ? extends R>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(Iterable<? extends NbpObservable<? extends T>>, Function<? super Object[], ? extends R>, boolean) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(Iterable<? extends NbpObservable<? extends T>>, Function<? super Object[], ? extends R>, boolean, int) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(NbpObservable<? extends T>[], Function<? super Object[], ? extends R>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(NbpObservable<? extends T>[], Function<? super Object[], ? extends R>, boolean) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(NbpObservable<? extends T>[], Function<? super Object[], ? extends R>, boolean, int) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(NbpObservable<? extends T1>, NbpObservable<? extends T2>, BiFunction<? super T1, ? super T2, ? extends R>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(NbpObservable<? extends T1>, NbpObservable<? extends T2>, NbpObservable<? extends T3>, Function3<? super T1, ? super T2, ? super T3, ? extends R>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(NbpObservable<? extends T1>, NbpObservable<? extends T2>, NbpObservable<? extends T3>, NbpObservable<? extends T4>, Function4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(NbpObservable<? extends T1>, NbpObservable<? extends T2>, NbpObservable<? extends T3>, NbpObservable<? extends T4>, NbpObservable<? extends T5>, Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(NbpObservable<? extends T1>, NbpObservable<? extends T2>, NbpObservable<? extends T3>, NbpObservable<? extends T4>, NbpObservable<? extends T5>, NbpObservable<? extends T6>, Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(NbpObservable<? extends T1>, NbpObservable<? extends T2>, NbpObservable<? extends T3>, NbpObservable<? extends T4>, NbpObservable<? extends T5>, NbpObservable<? extends T6>, NbpObservable<? extends T7>, Function7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(NbpObservable<? extends T1>, NbpObservable<? extends T2>, NbpObservable<? extends T3>, NbpObservable<? extends T4>, NbpObservable<? extends T5>, NbpObservable<? extends T6>, NbpObservable<? extends T7>, NbpObservable<? extends T8>, Function8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(NbpObservable<? extends T1>, NbpObservable<? extends T2>, NbpObservable<? extends T3>, NbpObservable<? extends T4>, NbpObservable<? extends T5>, NbpObservable<? extends T6>, NbpObservable<? extends T7>, NbpObservable<? extends T8>, NbpObservable<? extends T9>, Function9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- combineLatest(Function<? super Object[], ? extends R>, boolean, int, Publisher<? extends T>...) - Static method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Iterable<? extends Publisher<? extends T>>, Function<? super Object[], ? extends R>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Iterable<? extends Publisher<? extends T>>, Function<? super Object[], ? extends R>, boolean) - Static method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Iterable<? extends Publisher<? extends T>>, Function<? super Object[], ? extends R>, boolean, int) - Static method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Publisher<? extends T>[], Function<? super Object[], ? extends R>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Publisher<? extends T>[], Function<? super Object[], ? extends R>, boolean) - Static method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Publisher<? extends T>[], Function<? super Object[], ? extends R>, boolean, int) - Static method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, BiFunction<? super T1, ? super T2, ? extends R>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Function3<? super T1, ? super T2, ? super T3, ? extends R>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Function4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Publisher<? extends T6>, Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Publisher<? extends T6>, Publisher<? extends T7>, Function7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Publisher<? extends T6>, Publisher<? extends T7>, Publisher<? extends T8>, Function8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Publisher<? extends T6>, Publisher<? extends T7>, Publisher<? extends T8>, Publisher<? extends T9>, Function9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- compare(int, int) - Static method in enum hu.akarnokd.rxjava2.internal.functions.Objects
-
Compares two integer values similar to Integer.compare.
- compare(long, long) - Static method in enum hu.akarnokd.rxjava2.internal.functions.Objects
-
Compares two integer values similar to Long.compare.
- Completable - Class in hu.akarnokd.rxjava2
-
Represents a deferred computation without any value but only indication for completion or exception.
- Completable(Completable.CompletableOnSubscribe) - Constructor for class hu.akarnokd.rxjava2.Completable
-
Constructs a Completable instance with the given onSubscribe callback.
- Completable.CompletableOnSubscribe - Interface in hu.akarnokd.rxjava2
-
Callback used for building deferred computations that takes a CompletableSubscriber.
- Completable.CompletableOperator - Interface in hu.akarnokd.rxjava2
-
Convenience interface and callback used by the lift operator that given a child CompletableSubscriber,
return a parent CompletableSubscriber that does any kind of lifecycle-related transformations.
- Completable.CompletableSubscriber - Interface in hu.akarnokd.rxjava2
-
Represents the subscription API callbacks when subscribing to a Completable instance.
- Completable.CompletableTransformer - Interface in hu.akarnokd.rxjava2
-
Convenience interface and callback used by the compose operator to turn a Completable into another
Completable fluently.
- CompletableOnSubscribeConcat - Class in hu.akarnokd.rxjava2.internal.operators.completable
-
- CompletableOnSubscribeConcat(Observable<? extends Completable>, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeConcat
-
- CompletableOnSubscribeConcatArray - Class in hu.akarnokd.rxjava2.internal.operators.completable
-
- CompletableOnSubscribeConcatArray(Completable[]) - Constructor for class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeConcatArray
-
- CompletableOnSubscribeConcatIterable - Class in hu.akarnokd.rxjava2.internal.operators.completable
-
- CompletableOnSubscribeConcatIterable(Iterable<? extends Completable>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeConcatIterable
-
- CompletableOnSubscribeMerge - Class in hu.akarnokd.rxjava2.internal.operators.completable
-
- CompletableOnSubscribeMerge(Observable<? extends Completable>, int, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeMerge
-
- CompletableOnSubscribeMergeArray - Class in hu.akarnokd.rxjava2.internal.operators.completable
-
- CompletableOnSubscribeMergeArray(Completable[]) - Constructor for class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeMergeArray
-
- CompletableOnSubscribeMergeDelayErrorArray - Class in hu.akarnokd.rxjava2.internal.operators.completable
-
- CompletableOnSubscribeMergeDelayErrorArray(Completable[]) - Constructor for class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeMergeDelayErrorArray
-
- CompletableOnSubscribeMergeDelayErrorIterable - Class in hu.akarnokd.rxjava2.internal.operators.completable
-
- CompletableOnSubscribeMergeDelayErrorIterable(Iterable<? extends Completable>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeMergeDelayErrorIterable
-
- CompletableOnSubscribeMergeIterable - Class in hu.akarnokd.rxjava2.internal.operators.completable
-
- CompletableOnSubscribeMergeIterable(Iterable<? extends Completable>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeMergeIterable
-
- CompletableOnSubscribeTimeout - Class in hu.akarnokd.rxjava2.internal.operators.completable
-
- CompletableOnSubscribeTimeout(Completable, long, TimeUnit, Scheduler, Completable) - Constructor for class hu.akarnokd.rxjava2.internal.operators.completable.CompletableOnSubscribeTimeout
-
- CompletableSerializedSubscriber - Class in hu.akarnokd.rxjava2.subscribers.completable
-
- CompletableSerializedSubscriber(Completable.CompletableSubscriber) - Constructor for class hu.akarnokd.rxjava2.subscribers.completable.CompletableSerializedSubscriber
-
- complete() - Static method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable instance that completes immediately when subscribed to.
- complete(NbpObservable.NbpSubscriber<?>) - Static method in enum hu.akarnokd.rxjava2.internal.disposables.EmptyDisposable
-
- complete(Subscriber<?>) - Static method in enum hu.akarnokd.rxjava2.internal.subscriptions.EmptySubscription
-
Sets the empty subscription instance on the subscriber and then
calls onComplete.
- complete() - Static method in enum hu.akarnokd.rxjava2.internal.util.NotificationLite
-
Returns a complete notification.
- complete() - Static method in class hu.akarnokd.rxjava2.Notification
-
- completions() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Returns the number of times onComplete was called.
- completions() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Returns the number of times onComplete was called.
- compose(Completable.CompletableTransformer) - Method in class hu.akarnokd.rxjava2.Completable
-
Calls the given transformer function with this instance and returns the function's resulting
Completable.
- compose(Function<? super NbpObservable<T>, ? extends NbpObservable<R>>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- compose(Observable.Transformer<T, R>) - Method in class hu.akarnokd.rxjava2.Observable
-
- compose(Function<? super Single<T>, ? extends Single<R>>) - Method in class hu.akarnokd.rxjava2.Single
-
- CompositeDisposable - Class in hu.akarnokd.rxjava2.disposables
-
A disposable container that can hold onto multiple other disposables.
- CompositeDisposable() - Constructor for class hu.akarnokd.rxjava2.disposables.CompositeDisposable
-
- CompositeDisposable(Disposable...) - Constructor for class hu.akarnokd.rxjava2.disposables.CompositeDisposable
-
- CompositeDisposable(Iterable<? extends Disposable>) - Constructor for class hu.akarnokd.rxjava2.disposables.CompositeDisposable
-
- CompositeException - Exception in hu.akarnokd.rxjava2.exceptions
-
A runtime exception that allows collecting multiple exceptions into one single instance.
- CompositeException() - Constructor for exception hu.akarnokd.rxjava2.exceptions.CompositeException
-
- CompositeException(String) - Constructor for exception hu.akarnokd.rxjava2.exceptions.CompositeException
-
- CompositeException(Iterable<? extends Throwable>) - Constructor for exception hu.akarnokd.rxjava2.exceptions.CompositeException
-
- CompositeException(Throwable...) - Constructor for exception hu.akarnokd.rxjava2.exceptions.CompositeException
-
- CompositeResource<T> - Interface in hu.akarnokd.rxjava2.internal.disposables
-
- computation() - Static method in class hu.akarnokd.rxjava2.schedulers.Schedulers
-
- ComputationScheduler - Class in hu.akarnokd.rxjava2.internal.schedulers
-
Holds a fixed pool of worker threads and assigns them
to requested Scheduler.Workers in a round-robin fashion.
- ComputationScheduler() - Constructor for class hu.akarnokd.rxjava2.internal.schedulers.ComputationScheduler
-
Create a scheduler with pool size equal to the available processor
count and using least-recent worker selection policy.
- concat(Completable...) - Static method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable which completes only when all sources complete, one after another.
- concat(Iterable<? extends Completable>) - Static method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable which completes only when all sources complete, one after another.
- concat(Observable<? extends Completable>) - Static method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable which completes only when all sources complete, one after another.
- concat(Observable<? extends Completable>, int) - Static method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable which completes only when all sources complete, one after another.
- concat(int, Iterable<? extends NbpObservable<? extends T>>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- concat(Iterable<? extends NbpObservable<? extends T>>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- concat(NbpObservable<? extends NbpObservable<? extends T>>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- concat(NbpObservable<? extends NbpObservable<? extends T>>, int) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- concat(NbpObservable<? extends T>, NbpObservable<? extends T>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- concat(NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- concat(NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- concat(NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- concat(NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- concat(NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- concat(NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- concat(NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>, NbpObservable<? extends T>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- concat(int, Iterable<? extends Publisher<? extends T>>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- concat(Iterable<? extends Publisher<? extends T>>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- concat(Publisher<? extends Publisher<? extends T>>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- concat(Publisher<? extends Publisher<? extends T>>, int) - Static method in class hu.akarnokd.rxjava2.Observable
-
- concat(Publisher<? extends T>, Publisher<? extends T>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- concat(Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- concat(Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- concat(Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- concat(Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- concat(Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- concat(Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- concat(Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- concat(Iterable<? extends Single<? extends T>>) - Static method in class hu.akarnokd.rxjava2.Single
-
- concat(Observable<? extends Single<? extends T>>) - Static method in class hu.akarnokd.rxjava2.Single
-
- concat(Single<? extends T>, Single<? extends T>) - Static method in class hu.akarnokd.rxjava2.Single
-
- concat(Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class hu.akarnokd.rxjava2.Single
-
- concat(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class hu.akarnokd.rxjava2.Single
-
- concat(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class hu.akarnokd.rxjava2.Single
-
- concat(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class hu.akarnokd.rxjava2.Single
-
- concat(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class hu.akarnokd.rxjava2.Single
-
- concat(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class hu.akarnokd.rxjava2.Single
-
- concat(Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>, Single<? extends T>) - Static method in class hu.akarnokd.rxjava2.Single
-
- concatArray(int, NbpObservable<? extends T>...) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- concatArray(NbpObservable<? extends T>...) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
Concatenates a variable number of NbpObservable sources.
- concatArray(int, Publisher<? extends T>...) - Static method in class hu.akarnokd.rxjava2.Observable
-
- concatArray(Publisher<? extends T>...) - Static method in class hu.akarnokd.rxjava2.Observable
-
Concatenates a variable number of Observable sources.
- concatMap(Function<? super T, ? extends NbpObservable<? extends R>>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- concatMap(Function<? super T, ? extends NbpObservable<? extends R>>, int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- concatMap(Function<? super T, ? extends Publisher<? extends R>>) - Method in class hu.akarnokd.rxjava2.Observable
-
- concatMap(Function<? super T, ? extends Publisher<? extends R>>, int) - Method in class hu.akarnokd.rxjava2.Observable
-
- concatMapIterable(Function<? super T, ? extends Iterable<? extends U>>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- concatMapIterable(Function<? super T, ? extends Iterable<? extends U>>, int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- concatMapIterable(Function<? super T, ? extends Iterable<? extends U>>) - Method in class hu.akarnokd.rxjava2.Observable
-
- concatMapIterable(Function<? super T, ? extends Iterable<? extends U>>, int) - Method in class hu.akarnokd.rxjava2.Observable
-
- concatWith(Completable) - Method in class hu.akarnokd.rxjava2.Completable
-
Concatenates this Completable with another Completable.
- concatWith(NbpObservable<? extends T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- concatWith(Publisher<? extends T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- concatWith(Single<? extends T>) - Method in class hu.akarnokd.rxjava2.Single
-
- ConditionalSubscriber<T> - Interface in hu.akarnokd.rxjava2.internal.subscribers
-
An Subscriber with an additional onNextIf(T) method that
tells the caller the specified value has been accepted or
not.
- connect(Consumer<? super Disposable>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorPublish
-
- connect(Consumer<? super Disposable>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorReplay
-
- connect(Consumer<? super Disposable>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorPublish
-
- connect(Consumer<? super Disposable>) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorReplay
-
- connect(Consumer<? super Disposable>) - Method in class hu.akarnokd.rxjava2.observables.ConnectableObservable
-
Instructs the
ConnectableObservable to begin emitting the items from its underlying
Observable to its
Subscribers.
- connect() - Method in class hu.akarnokd.rxjava2.observables.ConnectableObservable
-
Instructs the
ConnectableObservable to begin emitting the items from its underlying
Observable to its
Subscribers.
- connect(Consumer<? super Disposable>) - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpConnectableObservable
-
Instructs the
ConnectableObservable to begin emitting the items from its underlying
Observable to its
Subscribers.
- connect() - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpConnectableObservable
-
Instructs the
ConnectableObservable to begin emitting the items from its underlying
Observable to its
Subscribers.
- ConnectableObservable<T> - Class in hu.akarnokd.rxjava2.observables
-
- ConnectableObservable(Publisher<T>) - Constructor for class hu.akarnokd.rxjava2.observables.ConnectableObservable
-
- consumeAndCancel() - Static method in enum hu.akarnokd.rxjava2.internal.subscriptions.SubscriptionHelper
-
Returns a consumer which calls cancel on the supplied Subscription.
- consumeAndDispose() - Static method in class hu.akarnokd.rxjava2.disposables.Disposables
-
Returns a consumer that calls dispose on the received Disposable.
- Consumer<T> - Interface in hu.akarnokd.rxjava2.functions
-
- consumerBuffer - Variable in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- consumerIndex - Variable in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- consumerMask - Variable in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- contains(Object) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue
-
- contains(Object) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- contains(Object) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- contains(Object) - Method in class hu.akarnokd.rxjava2.Observable
-
- contains(Object) - Method in class hu.akarnokd.rxjava2.Single
-
- contains(Object, BiPredicate<Object, Object>) - Method in class hu.akarnokd.rxjava2.Single
-
- containsAll(Collection<?>) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue
-
- containsAll(Collection<?>) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- count() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- count() - Method in class hu.akarnokd.rxjava2.Observable
-
- create(Completable.CompletableOnSubscribe) - Static method in class hu.akarnokd.rxjava2.Completable
-
Constructs a Completable instance by wrapping the given onSubscribe callback.
- create(NbpObservable<? extends T>, int) - Static method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorPublish
-
Creates a OperatorPublish instance to publish values of the given source observable.
- create(NbpObservable<? extends T>, Function<? super NbpObservable<T>, ? extends NbpObservable<R>>, int) - Static method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorPublish
-
- create(NbpObservable<? extends T>, int) - Static method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorReplay
-
Creates a replaying ConnectableObservable with a size bound buffer.
- create(NbpObservable<? extends T>, long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorReplay
-
Creates a replaying ConnectableObservable with a time bound buffer.
- create(NbpObservable<? extends T>, long, TimeUnit, Scheduler, int) - Static method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorReplay
-
Creates a replaying ConnectableObservable with a size and time bound buffer.
- create(Observable<? extends T>, int) - Static method in class hu.akarnokd.rxjava2.internal.operators.OperatorPublish
-
Creates a OperatorPublish instance to publish values of the given source observable.
- create(Observable<? extends T>, Function<? super Observable<T>, ? extends Publisher<R>>, int) - Static method in class hu.akarnokd.rxjava2.internal.operators.OperatorPublish
-
- create(Observable<? extends T>, int) - Static method in class hu.akarnokd.rxjava2.internal.operators.OperatorReplay
-
Creates a replaying ConnectableObservable with a size bound buffer.
- create(Observable<? extends T>, long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.rxjava2.internal.operators.OperatorReplay
-
Creates a replaying ConnectableObservable with a time bound buffer.
- create(Observable<? extends T>, long, TimeUnit, Scheduler, int) - Static method in class hu.akarnokd.rxjava2.internal.operators.OperatorReplay
-
Creates a replaying ConnectableObservable with a size and time bound buffer.
- create(ThreadFactory) - Static method in enum hu.akarnokd.rxjava2.internal.schedulers.SchedulerPoolFactory
-
Creates a ScheduledExecutorService with the given factory.
- create(NbpObservable.NbpOnSubscribe<T>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- create(Publisher<T>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- create(Single.SingleOnSubscribe<T>) - Static method in class hu.akarnokd.rxjava2.Single
-
- create() - Static method in class hu.akarnokd.rxjava2.subjects.AsyncSubject
-
Constructs an empty AsyncSubject.
- create() - Static method in class hu.akarnokd.rxjava2.subjects.BehaviorSubject
-
- create() - Static method in class hu.akarnokd.rxjava2.subjects.nbp.NbpAsyncSubject
-
- create() - Static method in class hu.akarnokd.rxjava2.subjects.nbp.NbpBehaviorSubject
-
- create() - Static method in class hu.akarnokd.rxjava2.subjects.nbp.NbpPublishSubject
-
- create() - Static method in class hu.akarnokd.rxjava2.subjects.nbp.NbpReplaySubject
-
- create(int) - Static method in class hu.akarnokd.rxjava2.subjects.nbp.NbpReplaySubject
-
- create() - Static method in class hu.akarnokd.rxjava2.subjects.nbp.NbpUnicastSubject
-
Creates an UnicastSubject with an internal buffer capacity hint 16.
- create(int) - Static method in class hu.akarnokd.rxjava2.subjects.nbp.NbpUnicastSubject
-
Creates an UnicastSubject with the given internal buffer capacity hint.
- create(int, Runnable) - Static method in class hu.akarnokd.rxjava2.subjects.nbp.NbpUnicastSubject
-
Creates an UnicastSubject with the given internal buffer capacity hint and a callback for
the case when the single Subscriber cancels its subscription.
- create() - Static method in class hu.akarnokd.rxjava2.subjects.PublishSubject
-
Constructs a PublishSubject.
- create() - Static method in class hu.akarnokd.rxjava2.subjects.ReplaySubject
-
- create(int) - Static method in class hu.akarnokd.rxjava2.subjects.ReplaySubject
-
- create() - Static method in class hu.akarnokd.rxjava2.subjects.UnicastSubject
-
Creates an UnicastSubject with an internal buffer capacity hint 16.
- create(int) - Static method in class hu.akarnokd.rxjava2.subjects.UnicastSubject
-
Creates an UnicastSubject with the given internal buffer capacity hint.
- create(int, Runnable) - Static method in class hu.akarnokd.rxjava2.subjects.UnicastSubject
-
Creates an UnicastSubject with the given internal buffer capacity hint and a callback for
the case when the single Subscriber cancels its subscription.
- create(Consumer<? super T>) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpObservers
-
- create(Consumer<? super T>, Consumer<? super Throwable>) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpObservers
-
- create(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpObservers
-
- create(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Runnable) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpObservers
-
- create(Consumer<? super T>) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSubscribers
-
- create(Consumer<? super T>, Consumer<? super Throwable>) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSubscribers
-
- create(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSubscribers
-
- create(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Consumer<? super Disposable>) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSubscribers
-
- create(Consumer<? super T>) - Static method in class hu.akarnokd.rxjava2.subscribers.Observers
-
- create(Consumer<? super T>, Consumer<? super Throwable>) - Static method in class hu.akarnokd.rxjava2.subscribers.Observers
-
- create(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Static method in class hu.akarnokd.rxjava2.subscribers.Observers
-
- create(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Runnable) - Static method in class hu.akarnokd.rxjava2.subscribers.Observers
-
- create(Consumer<? super T>) - Static method in class hu.akarnokd.rxjava2.subscribers.Subscribers
-
- create(Consumer<? super T>, Consumer<? super Throwable>) - Static method in class hu.akarnokd.rxjava2.subscribers.Subscribers
-
- create(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Static method in class hu.akarnokd.rxjava2.subscribers.Subscribers
-
- create(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Consumer<? super Subscription>) - Static method in class hu.akarnokd.rxjava2.subscribers.Subscribers
-
- createAsync(Consumer<? super T>) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpObservers
-
- createAsync(Consumer<? super T>, Consumer<? super Throwable>) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpObservers
-
- createAsync(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpObservers
-
- createAsync(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Runnable) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpObservers
-
- createAsync(Consumer<? super T>) - Static method in class hu.akarnokd.rxjava2.subscribers.Observers
-
- createAsync(Consumer<? super T>, Consumer<? super Throwable>) - Static method in class hu.akarnokd.rxjava2.subscribers.Observers
-
- createAsync(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Static method in class hu.akarnokd.rxjava2.subscribers.Observers
-
- createAsync(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Runnable) - Static method in class hu.akarnokd.rxjava2.subscribers.Observers
-
- createDefault(T) - Static method in class hu.akarnokd.rxjava2.subjects.BehaviorSubject
-
- createDefault(T) - Static method in class hu.akarnokd.rxjava2.subjects.nbp.NbpBehaviorSubject
-
- createDisposable(Consumer<? super T>) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSubscribers
-
- createDisposable(Consumer<? super T>, Consumer<? super Throwable>) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSubscribers
-
- createDisposable(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSubscribers
-
- createDisposable(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Runnable) - Static method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSubscribers
-
- createDisposable(Consumer<? super T>) - Static method in class hu.akarnokd.rxjava2.subscribers.Subscribers
-
- createDisposable(Consumer<? super T>, Consumer<? super Throwable>) - Static method in class hu.akarnokd.rxjava2.subscribers.Subscribers
-
- createDisposable(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Static method in class hu.akarnokd.rxjava2.subscribers.Subscribers
-
- createDisposable(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Runnable) - Static method in class hu.akarnokd.rxjava2.subscribers.Subscribers
-
- createFrom(NbpObservable<? extends T>) - Static method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorReplay
-
Creates a replaying ConnectableObservable with an unbounded buffer.
- createFrom(Observable<? extends T>) - Static method in class hu.akarnokd.rxjava2.internal.operators.OperatorReplay
-
Creates a replaying ConnectableObservable with an unbounded buffer.
- createWithSize(int) - Static method in class hu.akarnokd.rxjava2.subjects.nbp.NbpReplaySubject
-
- createWithSize(int) - Static method in class hu.akarnokd.rxjava2.subjects.ReplaySubject
-
- createWithTime(long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.subjects.nbp.NbpReplaySubject
-
- createWithTime(long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.rxjava2.subjects.nbp.NbpReplaySubject
-
- createWithTime(long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.subjects.ReplaySubject
-
- createWithTime(long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.rxjava2.subjects.ReplaySubject
-
- createWithTimeAndSize(long, TimeUnit, Scheduler, int) - Static method in class hu.akarnokd.rxjava2.subjects.nbp.NbpReplaySubject
-
- createWithTimeAndSize(long, TimeUnit, Scheduler, int) - Static method in class hu.akarnokd.rxjava2.subjects.ReplaySubject
-
- createWorker() - Method in class hu.akarnokd.rxjava2.internal.schedulers.ComputationScheduler
-
- createWorker() - Method in class hu.akarnokd.rxjava2.internal.schedulers.ExecutorScheduler
-
- createWorker() - Method in class hu.akarnokd.rxjava2.internal.schedulers.IOScheduler
-
- createWorker() - Method in class hu.akarnokd.rxjava2.internal.schedulers.NewThreadScheduler
-
- createWorker() - Method in class hu.akarnokd.rxjava2.internal.schedulers.SingleScheduler
-
- createWorker() - Method in class hu.akarnokd.rxjava2.internal.schedulers.TrampolineScheduler
-
- createWorker() - Method in class hu.akarnokd.rxjava2.Scheduler
-
- createWorker() - Method in class hu.akarnokd.rxjava2.schedulers.TestScheduler
-
- naturalOrder() - Static method in enum hu.akarnokd.rxjava2.internal.functions.Functions
-
Returns a natural order comparator which casts the parameters to Comparable.
- NbpAsyncObserver<T> - Class in hu.akarnokd.rxjava2.subscribers.nbp
-
An abstract Subscriber implementation that allows asynchronous cancellation of its
subscription.
- NbpAsyncObserver() - Constructor for class hu.akarnokd.rxjava2.subscribers.nbp.NbpAsyncObserver
-
Constructs an AsyncObserver with resource support.
- NbpAsyncObserver(boolean) - Constructor for class hu.akarnokd.rxjava2.subscribers.nbp.NbpAsyncObserver
-
Constructs an AsyncObserver and allows specifying if it should support resources or not.
- NbpAsyncSubject<T> - Class in hu.akarnokd.rxjava2.subjects.nbp
-
An NbpSubject that emits the very last value followed by a completion event or the received error to NbpSubscribers.
- NbpAsyncSubject(NbpAsyncSubject.State<T>) - Constructor for class hu.akarnokd.rxjava2.subjects.nbp.NbpAsyncSubject
-
- NbpBehaviorSubject<T> - Class in hu.akarnokd.rxjava2.subjects.nbp
-
- NbpBehaviorSubject(NbpBehaviorSubject.State<T>) - Constructor for class hu.akarnokd.rxjava2.subjects.nbp.NbpBehaviorSubject
-
- NbpBlockingObservable<T> - Class in hu.akarnokd.rxjava2.observables.nbp
-
- NbpBlockingObservable(NbpObservable<? extends T>) - Constructor for class hu.akarnokd.rxjava2.observables.nbp.NbpBlockingObservable
-
- NbpBlockingOperatorLatest - Enum in hu.akarnokd.rxjava2.internal.operators.nbp
-
Wait for and iterate over the latest values of the source observable.
- NbpBlockingOperatorMostRecent - Enum in hu.akarnokd.rxjava2.internal.operators.nbp
-
Returns an Iterable that always returns the item most recently emitted by an Observable, or a
seed value if no item has yet been emitted.
- NbpBlockingOperatorNext - Enum in hu.akarnokd.rxjava2.internal.operators.nbp
-
Returns an Iterable that blocks until the Observable emits another item, then returns that item.
- NbpBlockingSubscriber<T> - Class in hu.akarnokd.rxjava2.internal.subscribers.nbp
-
- NbpBlockingSubscriber(Queue<Object>) - Constructor for class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpBlockingSubscriber
-
- NbpCachedObservable<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
An observable which auto-connects to another observable, caches the elements
from that observable but allows terminating the connection and completing the cache.
- NbpCancelledSubscriber - Enum in hu.akarnokd.rxjava2.internal.subscribers.nbp
-
A subscriber that cancels the subscription sent to it
and ignores all events (onError is forwarded to RxJavaPlugins though).
- NbpConditionalSubscriber<T> - Interface in hu.akarnokd.rxjava2.internal.subscribers.nbp
-
An Subscriber with an additional onNextIf(T) method that
tells the caller the specified value has been accepted or
not.
- NbpConnectableObservable<T> - Class in hu.akarnokd.rxjava2.observables.nbp
-
- NbpConnectableObservable(NbpObservable.NbpOnSubscribe<T>) - Constructor for class hu.akarnokd.rxjava2.observables.nbp.NbpConnectableObservable
-
- NbpDisposableSubscriber<T> - Class in hu.akarnokd.rxjava2.internal.subscribers.nbp
-
An abstract subscription that allows asynchronous cancellation.
- NbpDisposableSubscriber() - Constructor for class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpDisposableSubscriber
-
- NbpEmptySubscriber - Enum in hu.akarnokd.rxjava2.internal.subscribers.nbp
-
A subscriber that ignores all events (onError is forwarded to RxJavaPlugins though).
- NbpFullArbiter<T> - Class in hu.akarnokd.rxjava2.internal.disposables
-
Performs full arbitration of Subscriber events with strict drain (i.e., old emissions of another
subscriber are dropped).
- NbpFullArbiter(NbpObservable.NbpSubscriber<? super T>, Disposable, int) - Constructor for class hu.akarnokd.rxjava2.internal.disposables.NbpFullArbiter
-
- NbpFullArbiterSubscriber<T> - Class in hu.akarnokd.rxjava2.internal.subscribers
-
Subscriber that communicates with a FullArbiter.
- NbpFullArbiterSubscriber(NbpFullArbiter<T>) - Constructor for class hu.akarnokd.rxjava2.internal.subscribers.NbpFullArbiterSubscriber
-
- NbpGroupedObservable<K,T> - Class in hu.akarnokd.rxjava2.observables.nbp
-
- NbpGroupedObservable(NbpObservable.NbpOnSubscribe<T>, K) - Constructor for class hu.akarnokd.rxjava2.observables.nbp.NbpGroupedObservable
-
- NbpLambdaSubscriber<T> - Class in hu.akarnokd.rxjava2.internal.subscribers.nbp
-
- NbpLambdaSubscriber(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Consumer<? super Disposable>) - Constructor for class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpLambdaSubscriber
-
- NbpObservable<T> - Class in hu.akarnokd.rxjava2
-
Observable for delivering a sequence of values without backpressure.
- NbpObservable(NbpObservable.NbpOnSubscribe<T>) - Constructor for class hu.akarnokd.rxjava2.NbpObservable
-
- NbpObservable.NbpOnSubscribe<T> - Interface in hu.akarnokd.rxjava2
-
- NbpObservable.NbpOperator<Downstream,Upstream> - Interface in hu.akarnokd.rxjava2
-
- NbpObservable.NbpSubscriber<T> - Interface in hu.akarnokd.rxjava2
-
- NbpObservable.NbpTransformer<Upstream,Downstream> - Interface in hu.akarnokd.rxjava2
-
- NbpObservableScalarSource<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
Represents a constant scalar value.
- NbpObservableScalarSource(T) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpObservableScalarSource
-
- NbpObserver<T> - Class in hu.akarnokd.rxjava2
-
- NbpObserver() - Constructor for class hu.akarnokd.rxjava2.NbpObserver
-
- NbpObservers - Class in hu.akarnokd.rxjava2.subscribers.nbp
-
Utility class to create Observers from lambdas.
- NbpOnSubscribeAmb<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeAmb(NbpObservable<? extends T>[], Iterable<? extends NbpObservable<? extends T>>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeAmb
-
- NbpOnSubscribeArraySource<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeArraySource(T[]) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeArraySource
-
- NbpOnSubscribeAutoConnect<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
Wraps a ConnectableObservable and calls its connect() method once
the specified number of Subscribers have subscribed.
- NbpOnSubscribeAutoConnect(NbpConnectableObservable<? extends T>, int, Consumer<? super Disposable>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeAutoConnect
-
- NbpOnSubscribeCombineLatest<T,R> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeCombineLatest(NbpObservable<? extends T>[], Iterable<? extends NbpObservable<? extends T>>, Function<? super Object[], ? extends R>, int, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeCombineLatest
-
- NbpOnSubscribeDefer<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeDefer(Supplier<? extends NbpObservable<? extends T>>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeDefer
-
- NbpOnSubscribeDelaySubscriptionOther<T,U> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
Delays the subscription to the main source until the other
observable fires an event or completes.
- NbpOnSubscribeDelaySubscriptionOther(NbpObservable<? extends T>, NbpObservable<U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeDelaySubscriptionOther
-
- NbpOnSubscribeErrorSource<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeErrorSource(Supplier<? extends Throwable>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeErrorSource
-
- NbpOnSubscribeFutureSource<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeFutureSource(Future<? extends T>, long, TimeUnit) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeFutureSource
-
- NbpOnSubscribeGenerate<T,S> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeGenerate(Supplier<S>, BiFunction<S, NbpObservable.NbpSubscriber<T>, S>, Consumer<? super S>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeGenerate
-
- NbpOnSubscribeIntervalRangeSource - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeIntervalRangeSource(long, long, long, long, TimeUnit, Scheduler) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeIntervalRangeSource
-
- NbpOnSubscribeIntervalSource - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeIntervalSource(long, long, TimeUnit, Scheduler) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeIntervalSource
-
- NbpOnSubscribeIterableSource<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeIterableSource(Iterable<? extends T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeIterableSource
-
- NbpOnSubscribeLift<R,T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
Allows lifting operators into a chain of Publishers.
- NbpOnSubscribeLift(NbpObservable<? extends T>, NbpObservable.NbpOperator<? extends R, ? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeLift
-
- NbpOnSubscribeRedo<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeRedo(NbpObservable<? extends T>, Function<? super NbpObservable<Try<Optional<Object>>>, ? extends NbpObservable<?>>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeRedo
-
- NbpOnSubscribeRefCount<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
Returns an observable sequence that stays connected to the source as long as
there is at least one subscription to the observable sequence.
- NbpOnSubscribeRefCount(NbpConnectableObservable<? extends T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeRefCount
-
Constructor.
- NbpOnSubscribeRepeat<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeRepeat(NbpObservable<? extends T>, long) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeRepeat
-
- NbpOnSubscribeRepeatUntil<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeRepeatUntil(NbpObservable<? extends T>, BooleanSupplier) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeRepeatUntil
-
- NbpOnSubscribeRetryBiPredicate<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeRetryBiPredicate(NbpObservable<? extends T>, BiPredicate<? super Integer, ? super Throwable>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeRetryBiPredicate
-
- NbpOnSubscribeRetryPredicate<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeRetryPredicate(NbpObservable<? extends T>, long, Predicate<? super Throwable>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeRetryPredicate
-
- NbpOnSubscribeScalarAsyncSource<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeScalarAsyncSource(Callable<? extends T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeScalarAsyncSource
-
- NbpOnSubscribeSequenceEqual<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeSequenceEqual(NbpObservable<? extends T>, NbpObservable<? extends T>, BiPredicate<? super T, ? super T>, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeSequenceEqual
-
- NbpOnSubscribeSubscribeOn<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeSubscribeOn(NbpObservable<? extends T>, Scheduler) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeSubscribeOn
-
- NbpOnSubscribeTimerOnceSource - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeTimerOnceSource(long, TimeUnit, Scheduler) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeTimerOnceSource
-
- NbpOnSubscribeUsing<T,D> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeUsing(Supplier<? extends D>, Function<? super D, ? extends NbpObservable<? extends T>>, Consumer<? super D>, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeUsing
-
- NbpOnSubscribeZip<T,R> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeZip(NbpObservable<? extends T>[], Iterable<? extends NbpObservable<? extends T>>, Function<? super Object[], ? extends R>, int, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeZip
-
- NbpOnSubscribeZipIterable<T,U,V> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOnSubscribeZipIterable(NbpObservable<? extends T>, Iterable<U>, BiFunction<? super T, ? super U, ? extends V>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeZipIterable
-
- NbpOperatorAll<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorAll(Predicate<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorAll
-
- NbpOperatorAny<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorAny(Predicate<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorAny
-
- NbpOperatorBuffer<T,U extends java.util.Collection<? super T>> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorBuffer(int, int, Supplier<U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorBuffer
-
- NbpOperatorBufferBoundary<T,U extends java.util.Collection<? super T>,Open,Close> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorBufferBoundary(NbpObservable<? extends Open>, Function<? super Open, ? extends NbpObservable<? extends Close>>, Supplier<U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorBufferBoundary
-
- NbpOperatorBufferBoundarySupplier<T,U extends java.util.Collection<? super T>,B> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorBufferBoundarySupplier(Supplier<? extends NbpObservable<B>>, Supplier<U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorBufferBoundarySupplier
-
- NbpOperatorBufferExactBoundary<T,U extends java.util.Collection<? super T>,B> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorBufferExactBoundary(NbpObservable<B>, Supplier<U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorBufferExactBoundary
-
- NbpOperatorBufferTimed<T,U extends java.util.Collection<? super T>> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorBufferTimed(long, long, TimeUnit, Scheduler, Supplier<U>, int, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorBufferTimed
-
- NbpOperatorCollect<T,U> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorCollect(Supplier<? extends U>, BiConsumer<? super U, ? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorCollect
-
- NbpOperatorConcatMap<T,U> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorConcatMap(Function<? super T, ? extends NbpObservable<? extends U>>, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorConcatMap
-
- NbpOperatorCount - Enum in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorDebounce<T,U> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorDebounce(Function<? super T, ? extends NbpObservable<U>>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorDebounce
-
- NbpOperatorDebounceTimed<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorDebounceTimed(long, TimeUnit, Scheduler) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorDebounceTimed
-
- NbpOperatorDelay<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorDelay(long, TimeUnit, Scheduler, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorDelay
-
- NbpOperatorDematerialize - Enum in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorDistinct<T,K> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorDistinct(Function<? super T, K>, Supplier<? extends Predicate<? super K>>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorDistinct
-
- NbpOperatorDoOnEach<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorDoOnEach(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Runnable) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorDoOnEach
-
- NbpOperatorElementAt<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorElementAt(long, T) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorElementAt
-
- NbpOperatorFilter<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorFilter(Predicate<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorFilter
-
- NbpOperatorFlatMap<T,U> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorFlatMap(Function<? super T, ? extends NbpObservable<? extends U>>, boolean, int, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorFlatMap
-
- NbpOperatorGroupBy<T,K,V> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorGroupBy(Function<? super T, ? extends K>, Function<? super T, ? extends V>, int, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorGroupBy
-
- NbpOperatorGroupBy.GroupBySubscriber<T,K,V> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorIgnoreElements - Enum in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorMap<T,U> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorMap(Function<? super T, ? extends U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorMap
-
- NbpOperatorMapNotification<T,R> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorMapNotification(Function<? super T, ? extends NbpObservable<? extends R>>, Function<? super Throwable, ? extends NbpObservable<? extends R>>, Supplier<? extends NbpObservable<? extends R>>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorMapNotification
-
- NbpOperatorMaterialize - Enum in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorObserveOn<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorObserveOn(Scheduler, boolean, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorObserveOn
-
- NbpOperatorOnErrorNext<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorOnErrorNext(Function<? super Throwable, ? extends NbpObservable<? extends T>>, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorOnErrorNext
-
- NbpOperatorOnErrorReturn<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorOnErrorReturn(Function<? super Throwable, ? extends T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorOnErrorReturn
-
- NbpOperatorPublish<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
A connectable observable which shares an underlying source and dispatches source values to subscribers in a backpressure-aware
manner.
- NbpOperatorReplay<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorSampleTimed<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorSampleTimed(long, TimeUnit, Scheduler) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSampleTimed
-
- NbpOperatorSampleWithObservable<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorSampleWithObservable(NbpObservable<?>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSampleWithObservable
-
- NbpOperatorScan<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorScan(BiFunction<T, T, T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorScan
-
- NbpOperatorScanSeed<T,R> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorScanSeed(Supplier<R>, BiFunction<R, ? super T, R>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorScanSeed
-
- NbpOperatorSingle<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorSingle(T) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSingle
-
- NbpOperatorSkip<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorSkip(long) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSkip
-
- NbpOperatorSkipLast<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorSkipLast(int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSkipLast
-
- NbpOperatorSkipLastTimed<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorSkipLastTimed(long, TimeUnit, Scheduler, int, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSkipLastTimed
-
- NbpOperatorSkipUntil<T,U> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorSkipUntil(NbpObservable<U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSkipUntil
-
- NbpOperatorSkipWhile<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorSkipWhile(Predicate<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSkipWhile
-
- NbpOperatorSwitchIfEmpty<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorSwitchIfEmpty(NbpObservable<? extends T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSwitchIfEmpty
-
- NbpOperatorSwitchMap<T,R> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorSwitchMap(Function<? super T, ? extends NbpObservable<? extends R>>, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorSwitchMap
-
- NbpOperatorTake<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorTake(long) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTake
-
- NbpOperatorTakeLast<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorTakeLast(int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTakeLast
-
- NbpOperatorTakeLastOne - Enum in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorTakeLastTimed<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorTakeLastTimed(long, long, TimeUnit, Scheduler, int, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTakeLastTimed
-
- NbpOperatorTakeUntil<T,U> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorTakeUntil(NbpObservable<? extends U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTakeUntil
-
- NbpOperatorTakeUntilPredicate<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorTakeUntilPredicate(Predicate<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTakeUntilPredicate
-
- NbpOperatorTakeWhile<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorTakeWhile(Predicate<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTakeWhile
-
- NbpOperatorThrottleFirstTimed<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorThrottleFirstTimed(long, TimeUnit, Scheduler) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorThrottleFirstTimed
-
- NbpOperatorTimeInterval<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorTimeInterval(TimeUnit, Scheduler) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTimeInterval
-
- NbpOperatorTimeout<T,U,V> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorTimeout(Supplier<? extends NbpObservable<U>>, Function<? super T, ? extends NbpObservable<V>>, NbpObservable<? extends T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTimeout
-
- NbpOperatorTimeoutTimed<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorTimeoutTimed(long, TimeUnit, Scheduler, NbpObservable<? extends T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTimeoutTimed
-
- NbpOperatorToList<T,U extends java.util.Collection<? super T>> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorToList(Supplier<U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorToList
-
- NbpOperatorUnsubscribeOn<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorUnsubscribeOn(Scheduler) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorUnsubscribeOn
-
- NbpOperatorWindow<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorWindow(long, long, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorWindow
-
- NbpOperatorWindowBoundary<T,B> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorWindowBoundary(NbpObservable<B>, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorWindowBoundary
-
- NbpOperatorWindowBoundarySelector<T,B,V> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorWindowBoundarySelector(NbpObservable<B>, Function<? super B, ? extends NbpObservable<V>>, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorWindowBoundarySelector
-
- NbpOperatorWindowBoundarySupplier<T,B> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorWindowBoundarySupplier(Supplier<? extends NbpObservable<B>>, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorWindowBoundarySupplier
-
- NbpOperatorWindowTimed<T> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorWindowTimed(long, long, TimeUnit, Scheduler, long, int, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorWindowTimed
-
- NbpOperatorWithLatestFrom<T,U,R> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpOperatorWithLatestFrom(BiFunction<? super T, ? super U, ? extends R>, NbpObservable<? extends U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorWithLatestFrom
-
- NbpPublishSubject<T> - Class in hu.akarnokd.rxjava2.subjects.nbp
-
- NbpPublishSubject(NbpPublishSubject.State<T>) - Constructor for class hu.akarnokd.rxjava2.subjects.nbp.NbpPublishSubject
-
- NbpQueueDrain<T,U> - Interface in hu.akarnokd.rxjava2.internal.util
-
- NbpQueueDrainSubscriber<T,U,V> - Class in hu.akarnokd.rxjava2.internal.subscribers.nbp
-
Abstract base class for subscribers that hold another subscriber, a queue
and requires queue-drain behavior.
- NbpQueueDrainSubscriber(NbpObservable.NbpSubscriber<? super V>, Queue<U>) - Constructor for class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpQueueDrainSubscriber
-
- NbpReplaySubject<T> - Class in hu.akarnokd.rxjava2.subjects.nbp
-
Replays events to Subscribers.
- NbpReplaySubject(NbpReplaySubject.State<T>) - Constructor for class hu.akarnokd.rxjava2.subjects.nbp.NbpReplaySubject
-
- NbpSafeSubscriber<T> - Class in hu.akarnokd.rxjava2.subscribers.nbp
-
Wraps another Subscriber and ensures all onXXX methods conform the protocol
(except the requirement for serialized access).
- NbpSafeSubscriber(NbpObservable.NbpSubscriber<? super T>) - Constructor for class hu.akarnokd.rxjava2.subscribers.nbp.NbpSafeSubscriber
-
- NbpSerializedSubscriber<T> - Class in hu.akarnokd.rxjava2.subscribers.nbp
-
Serializes access to the onNext, onError and onComplete methods of another Subscriber.
- NbpSerializedSubscriber(NbpObservable.NbpSubscriber<? super T>) - Constructor for class hu.akarnokd.rxjava2.subscribers.nbp.NbpSerializedSubscriber
-
- NbpSerializedSubscriber(NbpObservable.NbpSubscriber<? super T>, boolean) - Constructor for class hu.akarnokd.rxjava2.subscribers.nbp.NbpSerializedSubscriber
-
- NbpSubject<T,R> - Class in hu.akarnokd.rxjava2.subjects.nbp
-
Represents a NbpSubscriber and a NbpObservable at the same time, allowing
multicasting events from a single source to multiple child Subscribers.
- NbpSubject(NbpObservable.NbpOnSubscribe<R>) - Constructor for class hu.akarnokd.rxjava2.subjects.nbp.NbpSubject
-
- NbpSubscriberResourceWrapper<T,R> - Class in hu.akarnokd.rxjava2.internal.operators.nbp
-
- NbpSubscriberResourceWrapper(NbpObservable.NbpSubscriber<? super T>, Consumer<? super R>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.nbp.NbpSubscriberResourceWrapper
-
- NbpSubscribers - Class in hu.akarnokd.rxjava2.subscribers.nbp
-
Utility class to construct various resource-holding and disposable Subscribers from lambdas.
- NbpSubscriptionLambdaSubscriber<T> - Class in hu.akarnokd.rxjava2.internal.subscribers.nbp
-
- NbpSubscriptionLambdaSubscriber(NbpObservable.NbpSubscriber<? super T>, Consumer<? super Disposable>, Runnable) - Constructor for class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpSubscriptionLambdaSubscriber
-
- NbpTestSubscriber<T> - Class in hu.akarnokd.rxjava2.subscribers.nbp
-
A subscriber that records events and allows making assertions about them.
- NbpTestSubscriber() - Constructor for class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Constructs a non-forwarding TestSubscriber with an initial request value of Long.MAX_VALUE.
- NbpTestSubscriber(NbpObservable.NbpSubscriber<? super T>) - Constructor for class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Constructs a forwarding TestSubscriber but leaves the requesting to the wrapped subscriber.
- NbpToNotificationSubscriber<T> - Class in hu.akarnokd.rxjava2.internal.subscribers.nbp
-
- NbpToNotificationSubscriber(Consumer<? super Try<Optional<Object>>>) - Constructor for class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpToNotificationSubscriber
-
- NbpUnicastSubject<T> - Class in hu.akarnokd.rxjava2.subjects.nbp
-
Subject that allows only a single Subscriber to subscribe to it during its lifetime.
- NbpUnicastSubject(NbpUnicastSubject.State<T>) - Constructor for class hu.akarnokd.rxjava2.subjects.nbp.NbpUnicastSubject
-
Constructs the Observable base class.
- nest() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
Deprecated.
- nest() - Method in class hu.akarnokd.rxjava2.Observable
-
Deprecated.
- nest() - Method in class hu.akarnokd.rxjava2.Single
-
- never() - Static method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable that never calls onError or onComplete.
- never() - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- never() - Static method in class hu.akarnokd.rxjava2.Observable
-
- never() - Static method in class hu.akarnokd.rxjava2.Single
-
- newThread(Runnable) - Method in class hu.akarnokd.rxjava2.internal.schedulers.RxThreadFactory
-
- newThread() - Static method in class hu.akarnokd.rxjava2.schedulers.Schedulers
-
- NewThreadScheduler - Class in hu.akarnokd.rxjava2.internal.schedulers
-
Schedules work on a new thread.
- NewThreadWorker - Class in hu.akarnokd.rxjava2.internal.schedulers
-
Base class that manages a single-threaded ScheduledExecutorService as a
worker but doesn't perform task-tracking operations.
- NewThreadWorker(ThreadFactory) - Constructor for class hu.akarnokd.rxjava2.internal.schedulers.NewThreadWorker
-
- next(Publisher<? extends T>) - Static method in enum hu.akarnokd.rxjava2.internal.operators.BlockingOperatorNext
-
Returns an Iterable that blocks until the Observable emits another item, then returns
that item.
- next(NbpObservable<? extends T>) - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpBlockingOperatorNext
-
Returns an Iterable that blocks until the Observable emits another item, then returns
that item.
- next(T) - Static method in enum hu.akarnokd.rxjava2.internal.util.NotificationLite
-
Converts a value into a notification value.
- next(T) - Static method in class hu.akarnokd.rxjava2.Notification
-
- next() - Method in class hu.akarnokd.rxjava2.observables.BlockingObservable
-
- next() - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpBlockingObservable
-
- Notification - Class in hu.akarnokd.rxjava2
-
Utility class to help construct notification objects.
- NotificationLite - Enum in hu.akarnokd.rxjava2.internal.util
-
Lightweight notification handling utility class.
- now(TimeUnit) - Method in class hu.akarnokd.rxjava2.Scheduler
-
Returns the 'current time' of the Scheduler in the specified time unit.
- now(TimeUnit) - Method in class hu.akarnokd.rxjava2.Scheduler.Worker
-
Returns the 'current time' of the Worker in the specified time unit.
- now(TimeUnit) - Method in class hu.akarnokd.rxjava2.schedulers.TestScheduler
-
- nullSupplier() - Static method in enum hu.akarnokd.rxjava2.internal.functions.Functions
-
- Objects - Enum in hu.akarnokd.rxjava2.internal.functions
-
Utility methods containing the backport of Java 7's Objects utility class.
- Observable<T> - Class in hu.akarnokd.rxjava2
-
- Observable(Publisher<T>) - Constructor for class hu.akarnokd.rxjava2.Observable
-
- Observable.Operator<Downstream,Upstream> - Interface in hu.akarnokd.rxjava2
-
Interface to map/wrap a downstream subscriber to an upstream subscriber.
- Observable.Transformer<T,R> - Interface in hu.akarnokd.rxjava2
-
Interface to compose observables.
- ObservableScalarSource<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
Represents a constant scalar value.
- ObservableScalarSource(T) - Constructor for class hu.akarnokd.rxjava2.internal.operators.ObservableScalarSource
-
- observeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable which emits the terminal events from the thread of the specified scheduler.
- observeOn(NbpConnectableObservable<T>, Scheduler) - Static method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorReplay
-
Child Subscribers will observe the events of the ConnectableObservable on the
specified scheduler.
- observeOn(ConnectableObservable<T>, Scheduler) - Static method in class hu.akarnokd.rxjava2.internal.operators.OperatorReplay
-
Child Subscribers will observe the events of the ConnectableObservable on the
specified scheduler.
- observeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- observeOn(Scheduler, boolean) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- observeOn(Scheduler, boolean, int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- observeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- observeOn(Scheduler, boolean) - Method in class hu.akarnokd.rxjava2.Observable
-
- observeOn(Scheduler, boolean, int) - Method in class hu.akarnokd.rxjava2.Observable
-
- observeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.Single
-
- Observer<T> - Class in hu.akarnokd.rxjava2
-
- Observer() - Constructor for class hu.akarnokd.rxjava2.Observer
-
- Observers - Class in hu.akarnokd.rxjava2.subscribers
-
Utility class to create Observers from lambdas.
- of(T) - Static method in class hu.akarnokd.rxjava2.Optional
-
- ofError(Throwable) - Static method in class hu.akarnokd.rxjava2.Try
-
Constructs a Try instance by wrapping the given Throwable.
- offer(T) - Method in class hu.akarnokd.rxjava2.internal.queue.MpscLinkedQueue
-
IMPLEMENTATION NOTES:
Offer is allowed from multiple threads.
- offer(E) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscArrayQueue
-
- offer(T) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue
-
- offer(T) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
This implementation is correct for single producer thread use only.
- offer(T, T) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
Offer two elements at the same time.
- ofType(Class<U>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- ofType(Class<U>) - Method in class hu.akarnokd.rxjava2.Observable
-
- ofValue(T) - Static method in class hu.akarnokd.rxjava2.Try
-
Constructs a Try instance by wrapping the given value.
- onBackpressureBuffer() - Method in class hu.akarnokd.rxjava2.Observable
-
- onBackpressureBuffer(boolean) - Method in class hu.akarnokd.rxjava2.Observable
-
- onBackpressureBuffer(int) - Method in class hu.akarnokd.rxjava2.Observable
-
- onBackpressureBuffer(int, boolean) - Method in class hu.akarnokd.rxjava2.Observable
-
- onBackpressureBuffer(int, boolean, boolean) - Method in class hu.akarnokd.rxjava2.Observable
-
- onBackpressureBuffer(int, boolean, boolean, Runnable) - Method in class hu.akarnokd.rxjava2.Observable
-
- onBackpressureBuffer(int, Runnable) - Method in class hu.akarnokd.rxjava2.Observable
-
- onBackpressureDrop() - Method in class hu.akarnokd.rxjava2.Observable
-
- onBackpressureDrop(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- onBackpressureLatest() - Method in class hu.akarnokd.rxjava2.Observable
-
- onComplete() - Method in interface hu.akarnokd.rxjava2.Completable.CompletableSubscriber
-
Called once the deferred computation completes normally.
- onComplete(Disposable) - Method in class hu.akarnokd.rxjava2.internal.disposables.NbpFullArbiter
-
- onComplete() - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorGroupBy.GroupBySubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpSubscriberResourceWrapper
-
- onComplete() - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorGroupBy.GroupBySubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.internal.operators.SubscriberResourceWrapper
-
- onComplete() - Method in class hu.akarnokd.rxjava2.internal.subscribers.BlockingSubscriber
-
- onComplete() - Method in enum hu.akarnokd.rxjava2.internal.subscribers.CancelledSubscriber
-
- onComplete() - Method in enum hu.akarnokd.rxjava2.internal.subscribers.EmptySubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.internal.subscribers.FullArbiterSubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.internal.subscribers.LambdaSubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpBlockingSubscriber
-
- onComplete() - Method in enum hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpCancelledSubscriber
-
- onComplete() - Method in enum hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpEmptySubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpLambdaSubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpSubscriptionLambdaSubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpToNotificationSubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.internal.subscribers.NbpFullArbiterSubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.internal.subscribers.SubscriptionLambdaSubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.internal.subscribers.ToNotificationSubscriber
-
- onComplete(Subscription) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.FullArbiter
-
- onComplete() - Method in interface hu.akarnokd.rxjava2.NbpObservable.NbpSubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subjects.AsyncSubject
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subjects.BehaviorSubject
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpAsyncSubject
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpBehaviorSubject
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpPublishSubject
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpReplaySubject
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpUnicastSubject
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subjects.PublishSubject
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subjects.ReplaySubject
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subjects.UnicastSubject
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subscribers.completable.CompletableSerializedSubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSafeSubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSerializedSubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subscribers.SafeSubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subscribers.SerializedSubscriber
-
- onComplete() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
- OnCompleteFailedException - Exception in hu.akarnokd.rxjava2.exceptions
-
- OnCompleteFailedException(Throwable) - Constructor for exception hu.akarnokd.rxjava2.exceptions.OnCompleteFailedException
-
- onComputationScheduler(Scheduler) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- onCreate(Publisher<T>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
Called when an Observable is created.
- onError(Throwable) - Method in interface hu.akarnokd.rxjava2.Completable.CompletableSubscriber
-
Called once if the deferred computation 'throws' an exception.
- onError(Throwable, Disposable) - Method in class hu.akarnokd.rxjava2.internal.disposables.NbpFullArbiter
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorGroupBy.GroupBySubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpSubscriberResourceWrapper
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorGroupBy.GroupBySubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.internal.operators.SubscriberResourceWrapper
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.BlockingSubscriber
-
- onError(Throwable) - Method in enum hu.akarnokd.rxjava2.internal.subscribers.CancelledSubscriber
-
- onError(Throwable) - Method in enum hu.akarnokd.rxjava2.internal.subscribers.EmptySubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.FullArbiterSubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.LambdaSubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpBlockingSubscriber
-
- onError(Throwable) - Method in enum hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpCancelledSubscriber
-
- onError(Throwable) - Method in enum hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpEmptySubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpLambdaSubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpSubscriptionLambdaSubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpToNotificationSubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.NbpFullArbiterSubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.SubscriptionLambdaSubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.ToNotificationSubscriber
-
- onError(Throwable, Subscription) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.FullArbiter
-
- onError(Throwable) - Method in interface hu.akarnokd.rxjava2.NbpObservable.NbpSubscriber
-
- onError(Throwable) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
Called when an undeliverable error occurs.
- onError(Throwable) - Method in interface hu.akarnokd.rxjava2.Single.SingleSubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.AsyncSubject
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.BehaviorSubject
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpAsyncSubject
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpBehaviorSubject
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpPublishSubject
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpReplaySubject
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpUnicastSubject
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.PublishSubject
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.ReplaySubject
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subjects.UnicastSubject
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subscribers.completable.CompletableSerializedSubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSafeSubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSerializedSubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subscribers.SafeSubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subscribers.SerializedSubscriber
-
- onError(Throwable) - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
- onErrorComplete() - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable instance that if this Completable emits an error, it will emit an onComplete
and swallow the throwable.
- onErrorComplete(Predicate<? super Throwable>) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable instance that if this Completable emits an error and the predicate returns
true, it will emit an onComplete and swallow the throwable.
- OnErrorFailedException - Exception in hu.akarnokd.rxjava2.exceptions
-
- OnErrorFailedException(Throwable) - Constructor for exception hu.akarnokd.rxjava2.exceptions.OnErrorFailedException
-
- OnErrorNotImplementedException - Exception in hu.akarnokd.rxjava2.exceptions
-
- OnErrorNotImplementedException() - Constructor for exception hu.akarnokd.rxjava2.exceptions.OnErrorNotImplementedException
-
- OnErrorNotImplementedException(String, Throwable) - Constructor for exception hu.akarnokd.rxjava2.exceptions.OnErrorNotImplementedException
-
- OnErrorNotImplementedException(String) - Constructor for exception hu.akarnokd.rxjava2.exceptions.OnErrorNotImplementedException
-
- OnErrorNotImplementedException(Throwable) - Constructor for exception hu.akarnokd.rxjava2.exceptions.OnErrorNotImplementedException
-
- onErrorResumeNext(Function<? super Throwable, ? extends Completable>) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable instance that when encounters an error from this Completable, calls the
specified mapper function that returns another Completable instance for it and resumes the
execution with it.
- onErrorResumeNext(Function<? super Throwable, ? extends NbpObservable<? extends T>>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- onErrorResumeNext(NbpObservable<? extends T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- onErrorResumeNext(Function<? super Throwable, ? extends Publisher<? extends T>>) - Method in class hu.akarnokd.rxjava2.Observable
-
- onErrorResumeNext(Publisher<? extends T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- onErrorResumeNext(Function<? super Throwable, ? extends Single<? extends T>>) - Method in class hu.akarnokd.rxjava2.Single
-
- onErrorReturn(Function<? super Throwable, ? extends T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- onErrorReturn(Function<? super Throwable, ? extends T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- onErrorReturn(Supplier<? extends T>) - Method in class hu.akarnokd.rxjava2.Single
-
- onErrorReturn(T) - Method in class hu.akarnokd.rxjava2.Single
-
- onErrorReturnValue(T) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- onErrorReturnValue(T) - Method in class hu.akarnokd.rxjava2.Observable
-
- onExceptionResumeNext(NbpObservable<? extends T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- onExceptionResumeNext(Publisher<? extends T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- onIOScheduler(Scheduler) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- onNbpSubscribe(NbpObservable.NbpSubscriber<T>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
Called when a subscriber subscribes to an observable.
- onNewThreadScheduler(Scheduler) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- onNext(T, Disposable) - Method in class hu.akarnokd.rxjava2.internal.disposables.NbpFullArbiter
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorGroupBy.GroupBySubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpSubscriberResourceWrapper
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorGroupBy.GroupBySubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.internal.operators.SubscriberResourceWrapper
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.internal.subscribers.BlockingSubscriber
-
- onNext(Object) - Method in enum hu.akarnokd.rxjava2.internal.subscribers.CancelledSubscriber
-
- onNext(Object) - Method in enum hu.akarnokd.rxjava2.internal.subscribers.EmptySubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.internal.subscribers.FullArbiterSubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.internal.subscribers.LambdaSubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpBlockingSubscriber
-
- onNext(Object) - Method in enum hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpCancelledSubscriber
-
- onNext(Object) - Method in enum hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpEmptySubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpLambdaSubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpSubscriptionLambdaSubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpToNotificationSubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.internal.subscribers.NbpFullArbiterSubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.internal.subscribers.SubscriptionLambdaSubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.internal.subscribers.ToNotificationSubscriber
-
- onNext(T, Subscription) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.FullArbiter
-
- onNext(T) - Method in interface hu.akarnokd.rxjava2.NbpObservable.NbpSubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subjects.AsyncSubject
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subjects.BehaviorSubject
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpAsyncSubject
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpBehaviorSubject
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpPublishSubject
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpReplaySubject
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpUnicastSubject
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subjects.PublishSubject
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subjects.ReplaySubject
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subjects.UnicastSubject
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSafeSubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSerializedSubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subscribers.SafeSubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subscribers.SerializedSubscriber
-
- onNext(T) - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
- onNextIf(T) - Method in interface hu.akarnokd.rxjava2.internal.subscribers.ConditionalSubscriber
-
Conditionally takes the value.
- onNextIf(T) - Method in interface hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpConditionalSubscriber
-
Conditionally takes the value.
- onSchedule(Runnable) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
Called when a task is scheduled.
- onSingleScheduler(Scheduler) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- onStart() - Method in class hu.akarnokd.rxjava2.internal.subscribers.DisposableSubscriber
-
- onStart() - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpDisposableSubscriber
-
- onStart() - Method in class hu.akarnokd.rxjava2.NbpObserver
-
Called once the subscription has been set on this observer; override this
to perform initialization.
- onStart() - Method in class hu.akarnokd.rxjava2.Observer
-
Called once the subscription has been set on this observer; override this
to perform initialization or issue an initial request.
- onStart() - Method in class hu.akarnokd.rxjava2.subscribers.AsyncObserver
-
Called once the upstream sets a Subscription on this AsyncObserver.
- onStart() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpAsyncObserver
-
Called once the upstream sets a Subscription on this AsyncObserver.
- onSubscribe(Disposable) - Method in interface hu.akarnokd.rxjava2.Completable.CompletableSubscriber
-
Called once by the Completable to set a Disposable on this instance which
then can be used to cancel the subscription at any time.
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorGroupBy.GroupBySubscriber
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpSubscriberResourceWrapper
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorGroupBy.GroupBySubscriber
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.internal.operators.SubscriberResourceWrapper
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.internal.subscribers.BlockingSubscriber
-
- onSubscribe(Subscription) - Method in enum hu.akarnokd.rxjava2.internal.subscribers.CancelledSubscriber
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.internal.subscribers.DisposableSubscriber
-
- onSubscribe(Subscription) - Method in enum hu.akarnokd.rxjava2.internal.subscribers.EmptySubscriber
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.internal.subscribers.FullArbiterSubscriber
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.internal.subscribers.LambdaSubscriber
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpBlockingSubscriber
-
- onSubscribe(Disposable) - Method in enum hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpCancelledSubscriber
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpDisposableSubscriber
-
- onSubscribe(Disposable) - Method in enum hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpEmptySubscriber
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpLambdaSubscriber
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpSubscriptionLambdaSubscriber
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpToNotificationSubscriber
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.internal.subscribers.NbpFullArbiterSubscriber
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.internal.subscribers.SubscriptionLambdaSubscriber
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.internal.subscribers.ToNotificationSubscriber
-
- onSubscribe(Disposable) - Method in interface hu.akarnokd.rxjava2.NbpObservable.NbpSubscriber
-
- onSubscribe - Variable in class hu.akarnokd.rxjava2.NbpObservable
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.NbpObserver
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.Observer
-
- onSubscribe(Subscriber<T>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
Called when a subscriber subscribes to an observable.
- onSubscribe(NbpObservable.NbpSubscriber<T>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
Called when a subscriber subscribes to an observable.
- onSubscribe - Variable in class hu.akarnokd.rxjava2.Single
-
- onSubscribe(Disposable) - Method in interface hu.akarnokd.rxjava2.Single.SingleSubscriber
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.subjects.AsyncSubject
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.subjects.BehaviorSubject
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpAsyncSubject
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpBehaviorSubject
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpPublishSubject
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpReplaySubject
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpUnicastSubject
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.subjects.PublishSubject
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.subjects.ReplaySubject
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.subjects.UnicastSubject
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.subscribers.AsyncObserver
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.subscribers.completable.CompletableSerializedSubscriber
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpAsyncObserver
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSafeSubscriber
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpSerializedSubscriber
-
- onSubscribe(Disposable) - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.subscribers.SafeSubscriber
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.subscribers.SerializedSubscriber
-
- onSubscribe(Subscription) - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
- onSuccess(T) - Method in interface hu.akarnokd.rxjava2.Single.SingleSubscriber
-
- OpenHashSet<T> - Class in hu.akarnokd.rxjava2.internal.util
-
A simple open hash set with add, remove and clear capabilities only.
- OpenHashSet() - Constructor for class hu.akarnokd.rxjava2.internal.util.OpenHashSet
-
- OpenHashSet(int) - Constructor for class hu.akarnokd.rxjava2.internal.util.OpenHashSet
-
Creates an OpenHashSet with the initial capacity and load factor of 0.75f.
- OpenHashSet(int, float) - Constructor for class hu.akarnokd.rxjava2.internal.util.OpenHashSet
-
- operator() - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeLift
-
Returns the operator of this lift publisher.
- operator() - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherLift
-
Returns the operator of this lift publisher.
- OperatorAll<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorAll(Predicate<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorAll
-
- OperatorAny<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorAny(Predicate<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorAny
-
- OperatorBuffer<T,U extends java.util.Collection<? super T>> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorBuffer(int, int, Supplier<U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorBuffer
-
- OperatorBufferBoundary<T,U extends java.util.Collection<? super T>,Open,Close> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorBufferBoundary(Publisher<? extends Open>, Function<? super Open, ? extends Publisher<? extends Close>>, Supplier<U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorBufferBoundary
-
- OperatorBufferBoundarySupplier<T,U extends java.util.Collection<? super T>,B> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorBufferBoundarySupplier(Supplier<? extends Publisher<B>>, Supplier<U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorBufferBoundarySupplier
-
- OperatorBufferExactBoundary<T,U extends java.util.Collection<? super T>,B> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorBufferExactBoundary(Publisher<B>, Supplier<U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorBufferExactBoundary
-
- OperatorBufferTimed<T,U extends java.util.Collection<? super T>> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorBufferTimed(long, long, TimeUnit, Scheduler, Supplier<U>, int, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorBufferTimed
-
- OperatorCollect<T,U> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorCollect(Supplier<? extends U>, BiConsumer<? super U, ? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorCollect
-
- OperatorConcatMap<T,U> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorConcatMap(Function<? super T, ? extends Publisher<? extends U>>, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorConcatMap
-
- OperatorCount - Enum in hu.akarnokd.rxjava2.internal.operators
-
- OperatorDebounce<T,U> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorDebounce(Function<? super T, ? extends Publisher<U>>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorDebounce
-
- OperatorDebounceTimed<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorDebounceTimed(long, TimeUnit, Scheduler) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorDebounceTimed
-
- OperatorDelay<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorDelay(long, TimeUnit, Scheduler, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorDelay
-
- OperatorDematerialize - Enum in hu.akarnokd.rxjava2.internal.operators
-
- OperatorDistinct<T,K> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorDistinct(Function<? super T, K>, Supplier<? extends Predicate<? super K>>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorDistinct
-
- OperatorDoOnEach<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorDoOnEach(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Runnable) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorDoOnEach
-
- OperatorElementAt<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorElementAt(long, T) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorElementAt
-
- OperatorFilter<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorFilter(Predicate<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorFilter
-
- OperatorFlatMap<T,U> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorFlatMap(Function<? super T, ? extends Publisher<? extends U>>, boolean, int, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorFlatMap
-
- OperatorGroupBy<T,K,V> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorGroupBy(Function<? super T, ? extends K>, Function<? super T, ? extends V>, int, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorGroupBy
-
- OperatorGroupBy.GroupBySubscriber<T,K,V> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorIgnoreElements - Enum in hu.akarnokd.rxjava2.internal.operators
-
- OperatorMap<T,U> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorMap(Function<? super T, ? extends U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorMap
-
- OperatorMapNotification<T,R> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorMapNotification(Function<? super T, ? extends Publisher<? extends R>>, Function<? super Throwable, ? extends Publisher<? extends R>>, Supplier<? extends Publisher<? extends R>>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorMapNotification
-
- OperatorMaterialize - Enum in hu.akarnokd.rxjava2.internal.operators
-
- OperatorObserveOn<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorObserveOn(Scheduler, boolean, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorObserveOn
-
- OperatorOnBackpressureBuffer<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorOnBackpressureBuffer(int, boolean, boolean, Runnable) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorOnBackpressureBuffer
-
- OperatorOnBackpressureDrop<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorOnBackpressureDrop(Consumer<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorOnBackpressureDrop
-
- OperatorOnBackpressureLatest - Enum in hu.akarnokd.rxjava2.internal.operators
-
- OperatorOnErrorNext<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorOnErrorNext(Function<? super Throwable, ? extends Publisher<? extends T>>, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorOnErrorNext
-
- OperatorOnErrorReturn<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorOnErrorReturn(Function<? super Throwable, ? extends T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorOnErrorReturn
-
- OperatorPublish<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
A connectable observable which shares an underlying source and dispatches source values to subscribers in a backpressure-aware
manner.
- OperatorReplay<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorSamplePublisher<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorSamplePublisher(Publisher<?>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorSamplePublisher
-
- OperatorSampleTimed<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorSampleTimed(long, TimeUnit, Scheduler) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorSampleTimed
-
- OperatorScan<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorScan(BiFunction<T, T, T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorScan
-
- OperatorScanSeed<T,R> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorScanSeed(Supplier<R>, BiFunction<R, ? super T, R>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorScanSeed
-
- OperatorSingle<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorSingle(T) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorSingle
-
- OperatorSkip<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorSkip(long) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorSkip
-
- OperatorSkipLast<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorSkipLast(int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorSkipLast
-
- OperatorSkipLastTimed<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorSkipLastTimed(long, TimeUnit, Scheduler, int, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorSkipLastTimed
-
- OperatorSkipUntil<T,U> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorSkipUntil(Publisher<U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorSkipUntil
-
- OperatorSkipWhile<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorSkipWhile(Predicate<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorSkipWhile
-
- OperatorSwitchIfEmpty<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorSwitchIfEmpty(Publisher<? extends T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorSwitchIfEmpty
-
- OperatorSwitchMap<T,R> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorSwitchMap(Function<? super T, ? extends Publisher<? extends R>>, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorSwitchMap
-
- OperatorTake<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorTake(long) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorTake
-
- OperatorTakeLast<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorTakeLast(int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorTakeLast
-
- OperatorTakeLastOne - Enum in hu.akarnokd.rxjava2.internal.operators
-
- OperatorTakeLastTimed<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorTakeLastTimed(long, long, TimeUnit, Scheduler, int, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorTakeLastTimed
-
- OperatorTakeUntil<T,U> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorTakeUntil(Publisher<? extends U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorTakeUntil
-
- OperatorTakeUntilPredicate<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorTakeUntilPredicate(Predicate<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorTakeUntilPredicate
-
- OperatorTakeWhile<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorTakeWhile(Predicate<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorTakeWhile
-
- OperatorThrottleFirstTimed<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorThrottleFirstTimed(long, TimeUnit, Scheduler) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorThrottleFirstTimed
-
- OperatorTimeInterval<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorTimeInterval(TimeUnit, Scheduler) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorTimeInterval
-
- OperatorTimeout<T,U,V> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorTimeout(Supplier<? extends Publisher<U>>, Function<? super T, ? extends Publisher<V>>, Publisher<? extends T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorTimeout
-
- OperatorTimeoutTimed<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorTimeoutTimed(long, TimeUnit, Scheduler, Publisher<? extends T>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorTimeoutTimed
-
- OperatorToList<T,U extends java.util.Collection<? super T>> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorToList(Supplier<U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorToList
-
- OperatorUnsubscribeOn<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorUnsubscribeOn(Scheduler) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorUnsubscribeOn
-
- OperatorWindow<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorWindow(long, long, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorWindow
-
- OperatorWindowBoundary<T,B> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorWindowBoundary(Publisher<B>, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorWindowBoundary
-
- OperatorWindowBoundarySelector<T,B,V> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorWindowBoundarySelector(Publisher<B>, Function<? super B, ? extends Publisher<V>>, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorWindowBoundarySelector
-
- OperatorWindowBoundarySupplier<T,B> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorWindowBoundarySupplier(Supplier<? extends Publisher<B>>, int) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorWindowBoundarySupplier
-
- OperatorWindowTimed<T> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorWindowTimed(long, long, TimeUnit, Scheduler, long, int, boolean) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorWindowTimed
-
- OperatorWithLatestFrom<T,U,R> - Class in hu.akarnokd.rxjava2.internal.operators
-
- OperatorWithLatestFrom(BiFunction<? super T, ? super U, ? extends R>, Publisher<? extends U>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.OperatorWithLatestFrom
-
- Optional<T> - Class in hu.akarnokd.rxjava2
-
Simplified backport of Java 8's Optional type.
- Optional(T) - Constructor for class hu.akarnokd.rxjava2.Optional
-
- range(int, int) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- range(int, int) - Static method in class hu.akarnokd.rxjava2.Observable
-
- reduce(BiFunction<T, T, T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- reduce(R, BiFunction<R, ? super T, R>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- reduce(BiFunction<T, T, T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- reduce(R, BiFunction<R, ? super T, R>) - Method in class hu.akarnokd.rxjava2.Observable
-
- reduceWith(Supplier<R>, BiFunction<R, ? super T, R>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- reduceWith(Supplier<R>, BiFunction<R, ? super T, R>) - Method in class hu.akarnokd.rxjava2.Observable
-
- refCount() - Method in class hu.akarnokd.rxjava2.observables.ConnectableObservable
-
Returns an Observable that stays connected to this ConnectableObservable as long as there
is at least one subscription to this ConnectableObservable.
- refCount() - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpConnectableObservable
-
Returns an Observable that stays connected to this ConnectableObservable as long as there
is at least one subscription to this ConnectableObservable.
- RefCountDisposable - Class in hu.akarnokd.rxjava2.disposables
-
- RefCountDisposable(Disposable) - Constructor for class hu.akarnokd.rxjava2.disposables.RefCountDisposable
-
- remove(Disposable) - Method in class hu.akarnokd.rxjava2.disposables.CompositeDisposable
-
- remove(T) - Method in interface hu.akarnokd.rxjava2.internal.disposables.CompositeResource
-
- remove(T) - Method in class hu.akarnokd.rxjava2.internal.disposables.ListCompositeResource
-
Removes the given resource from this composite and calls the disposer if the resource
was indeed in the composite.
- remove(T) - Method in class hu.akarnokd.rxjava2.internal.disposables.SetCompositeResource
-
Removes the given resource from this composite and calls the disposer if the resource
was indeed in the composite.
- remove(Object) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue
-
- remove() - Method in class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue
-
- remove(Object) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- remove() - Method in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- remove(T) - Method in class hu.akarnokd.rxjava2.internal.util.OpenHashSet
-
- remove(AtomicReferenceFieldUpdater<T, U[]>, T, U, U[], U[], IntFunction<U[]>) - Static method in enum hu.akarnokd.rxjava2.internal.util.TerminalAtomicsHelper
-
Atomically replaces the array in instance with a new array that doesn't contain the
given value or returns false if the instance holds the terminal state or an empty array
or the value is not in the array.
- remove(AtomicReference<U[]>, U, U[], U[], IntFunction<U[]>) - Static method in enum hu.akarnokd.rxjava2.internal.util.TerminalAtomicsHelper
-
Atomically replaces the array in instance with a new array that doesn't contain the
given value or returns false if the instance holds the terminal state or an empty array
or the value is not in the array.
- removeAll(Collection<?>) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue
-
- removeAll(Collection<?>) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- repeat() - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable that repeatedly subscribes to this Completable until cancelled.
- repeat(long) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable that subscribes repeatedly at most the given times to this Completable.
- repeat() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- repeat(long) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- repeat() - Method in class hu.akarnokd.rxjava2.Observable
-
- repeat(long) - Method in class hu.akarnokd.rxjava2.Observable
-
- repeat() - Method in class hu.akarnokd.rxjava2.Single
-
- repeat(long) - Method in class hu.akarnokd.rxjava2.Single
-
- repeatUntil(BooleanSupplier) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable that repeatedly subscribes to this Completable so long as the given
stop supplier returns false.
- repeatUntil(BooleanSupplier) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- repeatUntil(BooleanSupplier) - Method in class hu.akarnokd.rxjava2.Observable
-
- repeatUntil(BooleanSupplier) - Method in class hu.akarnokd.rxjava2.Single
-
- repeatWhen(Function<? super Observable<Object>, ? extends Publisher<Object>>) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable instance that repeats when the Publisher returned by the handler
emits an item or completes when this Publisher emits a completed event.
- repeatWhen(Function<? super NbpObservable<Object>, ? extends NbpObservable<?>>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- repeatWhen(Function<? super Observable<Object>, ? extends Publisher<?>>) - Method in class hu.akarnokd.rxjava2.Observable
-
- repeatWhen(Function<? super Observable<Object>, ? extends Publisher<Object>>) - Method in class hu.akarnokd.rxjava2.Single
-
- replaceDisposable(Disposable) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.DisposableSubscription
-
Replaces any existing disposable with a new disposable but doesn't dispose the old one.
- replaceResource(int, T) - Method in class hu.akarnokd.rxjava2.internal.disposables.ArrayCompositeResource
-
Replaces the resource at the specified index and returns the old resource.
- replaceResource(Disposable) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.AsyncSubscription
-
Replaces the currently held resource with the given new one without disposing the old.
- replay() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(Function<? super NbpObservable<T>, ? extends NbpObservable<R>>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(Function<? super NbpObservable<T>, ? extends NbpObservable<R>>, int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(Function<? super NbpObservable<T>, ? extends NbpObservable<R>>, int, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(Function<? super NbpObservable<T>, ? extends NbpObservable<R>>, int, long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(Function<? super NbpObservable<T>, ? extends NbpObservable<R>>, int, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(Function<? super NbpObservable<T>, ? extends NbpObservable<R>>, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(Function<? super NbpObservable<T>, ? extends NbpObservable<R>>, long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(Function<? super NbpObservable<T>, ? extends NbpObservable<R>>, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(int, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(int, long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(int, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay(Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- replay() - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(Function<? super Observable<T>, ? extends Publisher<R>>) - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(Function<? super Observable<T>, ? extends Publisher<R>>, int) - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(Function<? super Observable<T>, ? extends Publisher<R>>, int, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(Function<? super Observable<T>, ? extends Publisher<R>>, int, long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(Function<? super Observable<T>, ? extends Publisher<R>>, int, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(Function<? super Observable<T>, ? extends Publisher<R>>, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(Function<? super Observable<T>, ? extends Publisher<R>>, long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(Function<? super Observable<T>, ? extends Publisher<R>>, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(int) - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(int, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(int, long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(int, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- replay(Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- ReplaySubject<T> - Class in hu.akarnokd.rxjava2.subjects
-
Replays events to Subscribers.
- ReplaySubject(ReplaySubject.State<T>) - Constructor for class hu.akarnokd.rxjava2.subjects.ReplaySubject
-
- reportDisposableSet() - Static method in enum hu.akarnokd.rxjava2.internal.subscriptions.SubscriptionHelper
-
Reports that the disposable is already set to the RxJavaPlugins error handler.
- reportSubscriptionSet() - Static method in enum hu.akarnokd.rxjava2.internal.subscriptions.SubscriptionHelper
-
Reports that the subscription is already set to the RxJavaPlugins error handler.
- request(long) - Method in class hu.akarnokd.rxjava2.internal.operators.OperatorGroupBy.GroupBySubscriber
-
- request(long) - Method in class hu.akarnokd.rxjava2.internal.operators.SubscriberResourceWrapper
-
- request(long) - Method in class hu.akarnokd.rxjava2.internal.subscribers.BlockingSubscriber
-
- request(long) - Method in class hu.akarnokd.rxjava2.internal.subscribers.DisposableSubscriber
-
- request(long) - Method in class hu.akarnokd.rxjava2.internal.subscribers.LambdaSubscriber
-
- request(long) - Method in class hu.akarnokd.rxjava2.internal.subscribers.SubscriptionLambdaSubscriber
-
- request(long) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.AsyncSubscription
-
- request(long) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.BooleanSubscription
-
- request(long) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.DisposableSubscription
-
- request(long) - Method in enum hu.akarnokd.rxjava2.internal.subscriptions.EmptySubscription
-
- request(long) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.FullArbiter
-
- request(long) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.ScalarAsyncSubscription
-
- request(long) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.ScalarSubscription
-
- request(long) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.SubscriptionArbiter
-
- request(long) - Method in class hu.akarnokd.rxjava2.Observer
-
- request(long) - Method in class hu.akarnokd.rxjava2.subscribers.AsyncObserver
-
Request the specified amount of elements from upstream.
- request(long) - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
- requested() - Method in class hu.akarnokd.rxjava2.internal.subscribers.QueueDrainSubscriber
-
- requested(long) - Method in class hu.akarnokd.rxjava2.internal.subscribers.QueueDrainSubscriber
-
- requested() - Method in interface hu.akarnokd.rxjava2.internal.util.QueueDrain
-
- requireNonNull(T, String) - Static method in enum hu.akarnokd.rxjava2.internal.functions.Objects
-
Verifies if the object is not null and returns it or throws a NullPointerException
with the given message.
- reset() - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
Removes all handlers and resets the default behavior.
- retainAll(Collection<?>) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue
-
- retainAll(Collection<?>) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- retry() - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable that retries this Completable as long as it emits an onError event.
- retry(BiPredicate<? super Integer, ? super Throwable>) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable that retries this Completable in case of an error as long as the predicate
returns true.
- retry(long) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable that when this Completable emits an error, retries at most the given
number of times before giving up and emitting the last error.
- retry(Predicate<? super Throwable>) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable that when this Completable emits an error, calls the given predicate with
the latest exception to decide whether to resubscribe to this or not.
- retry() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- retry(BiPredicate<? super Integer, ? super Throwable>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- retry(long) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- retry(long, Predicate<? super Throwable>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- retry(Predicate<? super Throwable>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- retry() - Method in class hu.akarnokd.rxjava2.Observable
-
- retry(BiPredicate<? super Integer, ? super Throwable>) - Method in class hu.akarnokd.rxjava2.Observable
-
- retry(long) - Method in class hu.akarnokd.rxjava2.Observable
-
- retry(long, Predicate<? super Throwable>) - Method in class hu.akarnokd.rxjava2.Observable
-
- retry(Predicate<? super Throwable>) - Method in class hu.akarnokd.rxjava2.Observable
-
- retry() - Method in class hu.akarnokd.rxjava2.Single
-
- retry(long) - Method in class hu.akarnokd.rxjava2.Single
-
- retry(BiPredicate<? super Integer, ? super Throwable>) - Method in class hu.akarnokd.rxjava2.Single
-
- retry(Predicate<? super Throwable>) - Method in class hu.akarnokd.rxjava2.Single
-
- retryUntil(BooleanSupplier) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- retryUntil(BooleanSupplier) - Method in class hu.akarnokd.rxjava2.Observable
-
- retryWhen(Function<? super Observable<? extends Throwable>, ? extends Publisher<Object>>) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable which given a Publisher and when this Completable emits an error, delivers
that error through an Observable and the Publisher should return a value indicating a retry in response
or a terminal event indicating a termination.
- retryWhen(Function<? super NbpObservable<? extends Throwable>, ? extends NbpObservable<?>>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- retryWhen(Function<? super Observable<? extends Throwable>, ? extends Publisher<?>>) - Method in class hu.akarnokd.rxjava2.Observable
-
- retryWhen(Function<? super Observable<? extends Throwable>, ? extends Publisher<Object>>) - Method in class hu.akarnokd.rxjava2.Single
-
- roundToPowerOfTwo(int) - Static method in class hu.akarnokd.rxjava2.internal.util.Pow2
-
Find the next larger positive power of two value up from the given value.
- run() - Method in class hu.akarnokd.rxjava2.internal.schedulers.ExecutorScheduler.ExecutorWorker
-
- run() - Method in class hu.akarnokd.rxjava2.internal.schedulers.ScheduledRunnable
-
- run() - Method in class hu.akarnokd.rxjava2.observables.BlockingObservable
-
Runs the source observable to a terminal event, ignoring any values and rethrowing any exception.
- run() - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpBlockingObservable
-
Runs the source observable to a terminal event, ignoring any values and rethrowing any exception.
- RxJavaPlugins - Class in hu.akarnokd.rxjava2.plugins
-
Utility class to inject handlers to certain standard RxJava operations.
- RxThreadFactory - Class in hu.akarnokd.rxjava2.internal.schedulers
-
- RxThreadFactory(String) - Constructor for class hu.akarnokd.rxjava2.internal.schedulers.RxThreadFactory
-
- safeSubscribe(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- safeSubscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- safeSubscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.Single
-
- SafeSubscriber<T> - Class in hu.akarnokd.rxjava2.subscribers
-
Wraps another Subscriber and ensures all onXXX methods conform the protocol
(except the requirement for serialized access).
- SafeSubscriber(Subscriber<? super T>) - Constructor for class hu.akarnokd.rxjava2.subscribers.SafeSubscriber
-
- sample(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- sample(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- sample(NbpObservable<U>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- sample(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- sample(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- sample(Publisher<U>) - Method in class hu.akarnokd.rxjava2.Observable
-
- ScalarAsyncSubscription<T> - Class in hu.akarnokd.rxjava2.internal.subscriptions
-
A Subscription that coordinates the emission of a single value set asynchronously.
- ScalarAsyncSubscription(Subscriber<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.subscriptions.ScalarAsyncSubscription
-
- scalarFlatMap(Function<? super T, ? extends NbpObservable<? extends U>>) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpObservableScalarSource
-
- scalarFlatMap(Function<? super T, ? extends Publisher<? extends U>>) - Method in class hu.akarnokd.rxjava2.internal.operators.ObservableScalarSource
-
- ScalarSubscription<T> - Class in hu.akarnokd.rxjava2.internal.subscriptions
-
A Subscription that holds a constant value and emits it only when requested.
- ScalarSubscription(Subscriber<? super T>, T) - Constructor for class hu.akarnokd.rxjava2.internal.subscriptions.ScalarSubscription
-
- scan(BiFunction<T, T, T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- scan(R, BiFunction<R, ? super T, R>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- scan(BiFunction<T, T, T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- scan(R, BiFunction<R, ? super T, R>) - Method in class hu.akarnokd.rxjava2.Observable
-
- scanWith(Supplier<R>, BiFunction<R, ? super T, R>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- scanWith(Supplier<R>, BiFunction<R, ? super T, R>) - Method in class hu.akarnokd.rxjava2.Observable
-
- schedule(Runnable) - Method in class hu.akarnokd.rxjava2.internal.schedulers.ExecutorScheduler.ExecutorWorker
-
- schedule(Runnable, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.internal.schedulers.ExecutorScheduler.ExecutorWorker
-
- schedule(Runnable) - Method in class hu.akarnokd.rxjava2.internal.schedulers.NewThreadWorker
-
- schedule(Runnable, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.internal.schedulers.NewThreadWorker
-
- schedule(Runnable, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Scheduler.Worker
-
- schedule(Runnable) - Method in class hu.akarnokd.rxjava2.Scheduler.Worker
-
- scheduleActual(Runnable, long, TimeUnit, CompositeResource<Disposable>) - Method in class hu.akarnokd.rxjava2.internal.schedulers.NewThreadWorker
-
Wraps the given runnable into a ScheduledRunnable and schedules it
on the underlying ScheduledExecutorService.
- scheduleDirect(Runnable, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.internal.schedulers.ComputationScheduler
-
- scheduleDirect(Runnable) - Method in class hu.akarnokd.rxjava2.internal.schedulers.ExecutorScheduler
-
- scheduleDirect(Runnable, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.internal.schedulers.ExecutorScheduler
-
- scheduleDirect(Runnable, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.internal.schedulers.NewThreadWorker
-
Schedules the given runnable on the underlying executor directly and
returns its future wrapped into a Disposable.
- scheduleDirect(Runnable, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.internal.schedulers.SingleScheduler
-
- scheduleDirect(Runnable) - Method in class hu.akarnokd.rxjava2.internal.schedulers.TrampolineScheduler
-
- scheduleDirect(Runnable, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.internal.schedulers.TrampolineScheduler
-
- scheduleDirect(Runnable) - Method in class hu.akarnokd.rxjava2.Scheduler
-
- scheduleDirect(Runnable, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Scheduler
-
Schedules the given runnable with the given delay directly on a worker of this scheduler.
- ScheduledRunnable - Class in hu.akarnokd.rxjava2.internal.schedulers
-
- ScheduledRunnable(Runnable, CompositeResource<Disposable>) - Constructor for class hu.akarnokd.rxjava2.internal.schedulers.ScheduledRunnable
-
Creates a ScheduledRunnable by wrapping the given action and setting
up the optional parent.
- schedulePeriodically(Runnable, long, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Scheduler.Worker
-
- schedulePeriodicallyDirect(Runnable, long, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.internal.schedulers.ComputationScheduler
-
- schedulePeriodicallyDirect(Runnable, long, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.internal.schedulers.ExecutorScheduler
-
- schedulePeriodicallyDirect(Runnable, long, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.internal.schedulers.NewThreadWorker
-
Schedules the given runnable periodically on the underlying executor directly
and returns its future wrapped into a Disposable.
- schedulePeriodicallyDirect(Runnable, long, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.internal.schedulers.SingleScheduler
-
- schedulePeriodicallyDirect(Runnable, long, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Scheduler
-
- Scheduler - Class in hu.akarnokd.rxjava2
-
- Scheduler() - Constructor for class hu.akarnokd.rxjava2.Scheduler
-
- Scheduler.Worker - Class in hu.akarnokd.rxjava2
-
- SchedulerKind - Enum in hu.akarnokd.rxjava2.annotations
-
Indicates what scheduler the method or class uses by default
- SchedulerLifecycle - Interface in hu.akarnokd.rxjava2.internal.schedulers
-
- SchedulerPoolFactory - Enum in hu.akarnokd.rxjava2.internal.schedulers
-
Manages the creating of ScheduledExecutorServices and sets up purging
- Schedulers - Class in hu.akarnokd.rxjava2.schedulers
-
- SchedulerSupport - Annotation Type in hu.akarnokd.rxjava2.annotations
-
Indicates what kind of scheduler the class or method uses.
- sequenceEqual(NbpObservable<? extends T>, NbpObservable<? extends T>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- sequenceEqual(NbpObservable<? extends T>, NbpObservable<? extends T>, BiPredicate<? super T, ? super T>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- sequenceEqual(NbpObservable<? extends T>, NbpObservable<? extends T>, BiPredicate<? super T, ? super T>, int) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- sequenceEqual(NbpObservable<? extends T>, NbpObservable<? extends T>, int) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- sequenceEqual(Publisher<? extends T>, Publisher<? extends T>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- sequenceEqual(Publisher<? extends T>, Publisher<? extends T>, BiPredicate<? super T, ? super T>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- sequenceEqual(Publisher<? extends T>, Publisher<? extends T>, BiPredicate<? super T, ? super T>, int) - Static method in class hu.akarnokd.rxjava2.Observable
-
- sequenceEqual(Publisher<? extends T>, Publisher<? extends T>, int) - Static method in class hu.akarnokd.rxjava2.Observable
-
- SerialDisposable - Class in hu.akarnokd.rxjava2.disposables
-
- SerialDisposable() - Constructor for class hu.akarnokd.rxjava2.disposables.SerialDisposable
-
- SerialDisposable(Disposable) - Constructor for class hu.akarnokd.rxjava2.disposables.SerialDisposable
-
- serialize() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- serialize() - Method in class hu.akarnokd.rxjava2.Observable
-
- SerializedSubscriber<T> - Class in hu.akarnokd.rxjava2.subscribers
-
Serializes access to the onNext, onError and onComplete methods of another Subscriber.
- SerializedSubscriber(Subscriber<? super T>) - Constructor for class hu.akarnokd.rxjava2.subscribers.SerializedSubscriber
-
- SerializedSubscriber(Subscriber<? super T>, boolean) - Constructor for class hu.akarnokd.rxjava2.subscribers.SerializedSubscriber
-
- SerialResource<T> - Class in hu.akarnokd.rxjava2.internal.disposables
-
Holds onto resources with a custom disposer callback and replacing a resource calls
the disposer with the old value.
- SerialResource(Consumer<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.disposables.SerialResource
-
Constructor with a custom disposer callback.
- SerialResource(Consumer<? super T>, T) - Constructor for class hu.akarnokd.rxjava2.internal.disposables.SerialResource
-
Constructor with a custom disposer callback and the initial resource
- set(Disposable) - Method in class hu.akarnokd.rxjava2.disposables.MultipleAssignmentDisposable
-
- set(Disposable) - Method in class hu.akarnokd.rxjava2.disposables.SerialDisposable
-
- set(AtomicReferenceFieldUpdater<T, U>, T, U, U, Consumer<? super U>) - Static method in enum hu.akarnokd.rxjava2.internal.util.TerminalAtomicsHelper
-
Atomically replaces the contents of the instance and calls the callback with the old value
or calls the callback with the new value if the instance holds the terminal value.
- set(AtomicReference<U>, U, U, Consumer<? super U>) - Static method in enum hu.akarnokd.rxjava2.internal.util.TerminalAtomicsHelper
-
Atomically replaces the contents of the instance and calls the callback with the old value
or calls the callback with the new value if the instance holds the terminal value.
- SetCompositeResource<T> - Class in hu.akarnokd.rxjava2.internal.disposables
-
A set-based composite resource with custom disposer callback.
- SetCompositeResource(Consumer<? super T>) - Constructor for class hu.akarnokd.rxjava2.internal.disposables.SetCompositeResource
-
- SetCompositeResource(Consumer<? super T>, T...) - Constructor for class hu.akarnokd.rxjava2.internal.disposables.SetCompositeResource
-
- SetCompositeResource(Consumer<? super T>, Iterable<? extends T>) - Constructor for class hu.akarnokd.rxjava2.internal.disposables.SetCompositeResource
-
- setComputationSchedulerHandler(Function<Scheduler, Scheduler>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- setCreateHandler(Function<Publisher<T>, Publisher<T>>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- setDisposable(Disposable) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.DisposableSubscription
-
Sets a new disposable resource and disposes any old one.
- setErrorHandler(Consumer<Throwable>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- setFirst(T) - Method in class hu.akarnokd.rxjava2.internal.util.AppendOnlyLinkedArrayList
-
Set a value as the first element of the list.
- setFuture(Future<?>) - Method in class hu.akarnokd.rxjava2.internal.schedulers.ScheduledRunnable
-
- setInitComputationSchedulerHandler(Function<Scheduler, Scheduler>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- setInitIOSchedulerHandler(Function<Scheduler, Scheduler>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- setInitNewThreadSchedulerHandler(Function<Scheduler, Scheduler>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- setInitSingleSchedulerHandler(Function<Scheduler, Scheduler>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- setIOSchedulerHandler(Function<Scheduler, Scheduler>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- setNbpSubscribeHandler(Function<NbpObservable.NbpSubscriber<T>, NbpObservable.NbpSubscriber<T>>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- setNewThreadSchedulerHandler(Function<Scheduler, Scheduler>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- setResource(int, T) - Method in class hu.akarnokd.rxjava2.internal.disposables.ArrayCompositeResource
-
Sets the resource at the specified index and disposes the old resource.
- setResource(T) - Method in class hu.akarnokd.rxjava2.internal.disposables.MultipleAssignmentResource
-
Atomically replaces the current resource with the new resource but doesn't call the disposer
for it.
- setResource(T) - Method in class hu.akarnokd.rxjava2.internal.disposables.SerialResource
-
Atomically replaces the current resource with the new resource but doesn't call the disposer
for it.
- setResource(R) - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpSubscriberResourceWrapper
-
- setResource(R) - Method in class hu.akarnokd.rxjava2.internal.operators.SubscriberResourceWrapper
-
- setResource(Disposable) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.AsyncSubscription
-
Sets a new resource and disposes the currently held resource.
- setScheduleHandler(Function<Runnable, Runnable>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- setSingleSchedulerHandler(Function<Scheduler, Scheduler>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- setSubscribeHandler(Function<Subscriber<T>, Subscriber<T>>) - Static method in class hu.akarnokd.rxjava2.plugins.RxJavaPlugins
-
- setSubscription(Disposable) - Method in class hu.akarnokd.rxjava2.internal.disposables.NbpFullArbiter
-
- setSubscription(Subscription) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.AsyncSubscription
-
Sets the given subscription if there isn't any subscription held.
- setSubscription(Subscription) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.FullArbiter
-
- setSubscription(Subscription) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.SubscriptionArbiter
-
- setValue(T) - Method in class hu.akarnokd.rxjava2.internal.subscriptions.ScalarAsyncSubscription
-
- share() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- share() - Method in class hu.akarnokd.rxjava2.Observable
-
- shutdown() - Method in class hu.akarnokd.rxjava2.internal.schedulers.ComputationScheduler
-
- shutdown() - Method in class hu.akarnokd.rxjava2.internal.schedulers.IOScheduler
-
- shutdown() - Method in interface hu.akarnokd.rxjava2.internal.schedulers.SchedulerLifecycle
-
- shutdown() - Static method in enum hu.akarnokd.rxjava2.internal.schedulers.SchedulerPoolFactory
-
Stops the purge thread.
- shutdown() - Method in class hu.akarnokd.rxjava2.internal.schedulers.SingleScheduler
-
- shutdown() - Method in class hu.akarnokd.rxjava2.Scheduler
-
- shutdown() - Static method in class hu.akarnokd.rxjava2.schedulers.Schedulers
-
- single() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- single(T) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- single() - Method in class hu.akarnokd.rxjava2.Observable
-
- single(T) - Method in class hu.akarnokd.rxjava2.Observable
-
- single() - Method in class hu.akarnokd.rxjava2.observables.BlockingObservable
-
- single(T) - Method in class hu.akarnokd.rxjava2.observables.BlockingObservable
-
- single() - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpBlockingObservable
-
- single(T) - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpBlockingObservable
-
- single() - Static method in class hu.akarnokd.rxjava2.schedulers.Schedulers
-
- Single<T> - Class in hu.akarnokd.rxjava2
-
Represents a deferred computation and emission of a single value or exception.
- Single(Single.SingleOnSubscribe<T>) - Constructor for class hu.akarnokd.rxjava2.Single
-
- Single.SingleOnSubscribe<T> - Interface in hu.akarnokd.rxjava2
-
- Single.SingleOperator<Downstream,Upstream> - Interface in hu.akarnokd.rxjava2
-
- Single.SingleSubscriber<T> - Interface in hu.akarnokd.rxjava2
-
- Single.SingleTransformer<Upstream,Downstream> - Interface in hu.akarnokd.rxjava2
-
- SingleOperatorFlatMap<T,R> - Class in hu.akarnokd.rxjava2.internal.operators.single
-
- SingleOperatorFlatMap(Function<? super T, ? extends Single<? extends R>>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.single.SingleOperatorFlatMap
-
- SingleOperatorMap<T,R> - Class in hu.akarnokd.rxjava2.internal.operators.single
-
- SingleOperatorMap(Function<? super T, ? extends R>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.single.SingleOperatorMap
-
- SingleScheduler - Class in hu.akarnokd.rxjava2.internal.schedulers
-
- SingleScheduler() - Constructor for class hu.akarnokd.rxjava2.internal.schedulers.SingleScheduler
-
- size() - Method in exception hu.akarnokd.rxjava2.exceptions.CompositeException
-
- size() - Method in class hu.akarnokd.rxjava2.internal.disposables.SetCompositeResource
-
- size() - Method in class hu.akarnokd.rxjava2.internal.queue.SpscArrayQueue
-
- size() - Method in class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue
-
- size() - Method in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- size() - Method in class hu.akarnokd.rxjava2.internal.schedulers.IOScheduler
-
- size() - Method in class hu.akarnokd.rxjava2.internal.util.LinkedArrayList
-
Returns the total size of the list.
- skip(long) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- skip(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- skip(long) - Method in class hu.akarnokd.rxjava2.Observable
-
- skip(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- skipLast(int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- skipLast(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- skipLast(long, TimeUnit, boolean) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- skipLast(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- skipLast(long, TimeUnit, Scheduler, boolean) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- skipLast(long, TimeUnit, Scheduler, boolean, int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- skipLast(int) - Method in class hu.akarnokd.rxjava2.Observable
-
- skipLast(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- skipLast(long, TimeUnit, boolean) - Method in class hu.akarnokd.rxjava2.Observable
-
- skipLast(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- skipLast(long, TimeUnit, Scheduler, boolean) - Method in class hu.akarnokd.rxjava2.Observable
-
- skipLast(long, TimeUnit, Scheduler, boolean, int) - Method in class hu.akarnokd.rxjava2.Observable
-
- skipUntil(NbpObservable<U>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- skipUntil(Publisher<U>) - Method in class hu.akarnokd.rxjava2.Observable
-
- skipWhile(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- skipWhile(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- soNext(LinkedQueueNode<E>) - Method in class hu.akarnokd.rxjava2.internal.queue.LinkedQueueNode
-
- source() - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeLift
-
Returns the source of this lift publisher.
- source() - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherLift
-
Returns the source of this lift publisher.
- SpscArrayQueue<E> - Class in hu.akarnokd.rxjava2.internal.queue
-
A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.
- SpscArrayQueue(int) - Constructor for class hu.akarnokd.rxjava2.internal.queue.SpscArrayQueue
-
- SpscExactArrayQueue<T> - Class in hu.akarnokd.rxjava2.internal.queue
-
A single-producer single-consumer array-backed queue with exact, non power-of-2 logical capacity.
- SpscExactArrayQueue(int) - Constructor for class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue
-
- SpscLinkedArrayQueue<T> - Class in hu.akarnokd.rxjava2.internal.queue
-
A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower
than the producer.
- SpscLinkedArrayQueue(int) - Constructor for class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- spValue(E) - Method in class hu.akarnokd.rxjava2.internal.queue.LinkedQueueNode
-
- start() - Method in class hu.akarnokd.rxjava2.internal.schedulers.ComputationScheduler
-
- start() - Method in class hu.akarnokd.rxjava2.internal.schedulers.IOScheduler
-
- start() - Method in interface hu.akarnokd.rxjava2.internal.schedulers.SchedulerLifecycle
-
- start() - Static method in enum hu.akarnokd.rxjava2.internal.schedulers.SchedulerPoolFactory
-
Starts the purge thread if not already started.
- start() - Method in class hu.akarnokd.rxjava2.internal.schedulers.SingleScheduler
-
- start() - Method in class hu.akarnokd.rxjava2.Scheduler
-
- start() - Static method in class hu.akarnokd.rxjava2.schedulers.Schedulers
-
- startWith(Completable) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable which first runs the other Completable
then this completable if the other completed normally.
- startWith(NbpObservable<T>) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns an NbpObservable which first delivers the events
of the other NbpObservable then runs this Completable.
- startWith(Observable<T>) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns an Observable which first delivers the events
of the other Observable then runs this Completable.
- startWith(Iterable<? extends T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- startWith(NbpObservable<? extends T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- startWith(T) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- startWith(Iterable<? extends T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- startWith(Publisher<? extends T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- startWith(T) - Method in class hu.akarnokd.rxjava2.Observable
-
- startWithArray(T...) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- startWithArray(T...) - Method in class hu.akarnokd.rxjava2.Observable
-
- Subject<T,R> - Class in hu.akarnokd.rxjava2.subjects
-
Represents a Subscriber and an Observable (Publisher) at the same time, allowing
multicasting events from a single source to multiple child Subscribers.
- Subject(Publisher<R>) - Constructor for class hu.akarnokd.rxjava2.subjects.Subject
-
- subscribe() - Method in class hu.akarnokd.rxjava2.Completable
-
Subscribes to this Completable and returns a Disposable which can be used to cancel
the subscription.
- subscribe(Completable.CompletableSubscriber) - Method in class hu.akarnokd.rxjava2.Completable
-
Subscribes the given CompletableSubscriber to this Completable instance.
- subscribe(Consumer<? super Throwable>, Runnable) - Method in class hu.akarnokd.rxjava2.Completable
-
Subscribes to this Completable and calls back either the onError or onComplete functions.
- subscribe(NbpObservable.NbpSubscriber<?>) - Method in class hu.akarnokd.rxjava2.Completable
-
Subscribes a non-backpressure NbpSubscriberto this Completable instance which
will receive only an onError or onComplete event.
- subscribe(Runnable) - Method in class hu.akarnokd.rxjava2.Completable
-
Subscribes to this Completable and calls the given Runnable when this Completable
completes normally.
- subscribe(Subscriber<T>) - Method in class hu.akarnokd.rxjava2.Completable
-
Subscribes a reactive-streams Subscriber to this Completable instance which
will receive only an onError or onComplete event.
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherAmb
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherArraySource
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherAutoConnect
-
- subscribe(Subscriber<? super R>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherCombineLatest
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherDefer
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherDelaySubscriptionOther
-
- subscribe(Subscriber<? super Object>) - Method in enum hu.akarnokd.rxjava2.internal.operators.PublisherEmptySource
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherErrorSource
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherFutureSource
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherGenerate
-
- subscribe(Subscriber<? super Long>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherIntervalOnceSource
-
- subscribe(Subscriber<? super Long>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherIntervalRangeSource
-
- subscribe(Subscriber<? super Long>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherIntervalSource
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherIterableSource
-
- subscribe(Subscriber<? super R>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherLift
-
- subscribe(Subscriber<? super Integer>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherRangeSource
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherRedo
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherRefCount
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherRepeat
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherRepeatUntil
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherRetryBiPredicate
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherRetryPredicate
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherScalarAsyncSource
-
- subscribe(Subscriber<? super Boolean>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherSequenceEqual
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherSubscribeOn
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherUsing
-
- subscribe(Subscriber<? super R>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherZip
-
- subscribe(Subscriber<? super V>) - Method in class hu.akarnokd.rxjava2.internal.operators.PublisherZipIterable
-
- subscribe() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- subscribe(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- subscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Consumer<? super Disposable>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- subscribe(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- subscribe() - Method in class hu.akarnokd.rxjava2.Observable
-
- subscribe(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- subscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class hu.akarnokd.rxjava2.Observable
-
- subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Method in class hu.akarnokd.rxjava2.Observable
-
- subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Consumer<? super Subscription>) - Method in class hu.akarnokd.rxjava2.Observable
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.observables.BlockingObservable
-
Subscribes to the source and calls the Subscriber methods on the current thread.
- subscribe() - Method in class hu.akarnokd.rxjava2.observables.BlockingObservable
-
Runs the source observable to a terminal event, ignoring any values and rethrowing any exception.
- subscribe(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.observables.BlockingObservable
-
Subscribes to the source and calls the given action on the current thread and rethrows any exception wrapped
into OnErrorNotImplementedException.
- subscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class hu.akarnokd.rxjava2.observables.BlockingObservable
-
Subscribes to the source and calls the given actions on the current thread.
- subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Method in class hu.akarnokd.rxjava2.observables.BlockingObservable
-
Subscribes to the source and calls the given actions on the current thread.
- subscribe(NbpObservable.NbpSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpBlockingObservable
-
Subscribes to the source and calls the Subscriber methods on the current thread.
- subscribe() - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpBlockingObservable
-
Runs the source observable to a terminal event, ignoring any values and rethrowing any exception.
- subscribe(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpBlockingObservable
-
Subscribes to the source and calls the given action on the current thread and rethrows any exception wrapped
into OnErrorNotImplementedException.
- subscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpBlockingObservable
-
Subscribes to the source and calls the given actions on the current thread.
- subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpBlockingObservable
-
Subscribes to the source and calls the given actions on the current thread.
- subscribe() - Method in class hu.akarnokd.rxjava2.Single
-
- subscribe(BiConsumer<? super T, ? super Throwable>) - Method in class hu.akarnokd.rxjava2.Single
-
- subscribe(Consumer<? super T>) - Method in class hu.akarnokd.rxjava2.Single
-
- subscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class hu.akarnokd.rxjava2.Single
-
- subscribe(Single.SingleSubscriber<? super T>) - Method in class hu.akarnokd.rxjava2.Single
-
- subscribe(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava2.Single
-
- subscribeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable which subscribes the child subscriber on the specified scheduler, making
sure the subscription side-effects happen on that specific thread of the scheduler.
- subscribeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- subscribeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- subscribeOn(Scheduler, boolean) - Method in class hu.akarnokd.rxjava2.Observable
-
- subscribeOn(Scheduler) - Method in class hu.akarnokd.rxjava2.Single
-
- SubscriberResourceWrapper<T,R> - Class in hu.akarnokd.rxjava2.internal.operators
-
- SubscriberResourceWrapper(Subscriber<? super T>, Consumer<? super R>) - Constructor for class hu.akarnokd.rxjava2.internal.operators.SubscriberResourceWrapper
-
- Subscribers - Class in hu.akarnokd.rxjava2.subscribers
-
Utility class to construct various resource-holding and disposable Subscribers from lambdas.
- subscription() - Method in class hu.akarnokd.rxjava2.internal.subscribers.DisposableSubscriber
-
- subscription(Subscription) - Static method in enum hu.akarnokd.rxjava2.internal.util.NotificationLite
-
Converts a Subscription into a notification value.
- subscription() - Method in class hu.akarnokd.rxjava2.Observer
-
- SubscriptionArbiter - Class in hu.akarnokd.rxjava2.internal.subscriptions
-
Arbitrates requests and cancellation between Subscriptions.
- SubscriptionArbiter() - Constructor for class hu.akarnokd.rxjava2.internal.subscriptions.SubscriptionArbiter
-
- SubscriptionHelper - Enum in hu.akarnokd.rxjava2.internal.subscriptions
-
Utility methods to validate Subscriptions and Disposables in the various onSubscribe calls.
- SubscriptionLambdaSubscriber<T> - Class in hu.akarnokd.rxjava2.internal.subscribers
-
- SubscriptionLambdaSubscriber(Subscriber<? super T>, Consumer<? super Subscription>, LongConsumer, Runnable) - Constructor for class hu.akarnokd.rxjava2.internal.subscribers.SubscriptionLambdaSubscriber
-
- Supplier<T> - Interface in hu.akarnokd.rxjava2.functions
-
- supportsResources() - Method in class hu.akarnokd.rxjava2.subscribers.AsyncObserver
-
Returns true if this AsyncObserver supports resources added via the add() method.
- supportsResources() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpAsyncObserver
-
Returns true if this AsyncObserver supports resources added via the add() method.
- suppress(Throwable) - Method in exception hu.akarnokd.rxjava2.exceptions.CompositeException
-
Adds a suppressed exception to this composite.
- switchIfEmpty(NbpObservable<? extends T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- switchIfEmpty(Publisher<? extends T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- switchMap(Function<? super T, ? extends NbpObservable<? extends R>>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- switchMap(Function<? super T, ? extends NbpObservable<? extends R>>, int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- switchMap(Function<? super T, ? extends Publisher<? extends R>>) - Method in class hu.akarnokd.rxjava2.Observable
-
- switchMap(Function<? super T, ? extends Publisher<? extends R>>, int) - Method in class hu.akarnokd.rxjava2.Observable
-
- switchOnNext(int, NbpObservable<? extends NbpObservable<? extends T>>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- switchOnNext(NbpObservable<? extends NbpObservable<? extends T>>) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- switchOnNext(int, Publisher<? extends Publisher<? extends T>>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- switchOnNext(Publisher<? extends Publisher<? extends T>>) - Static method in class hu.akarnokd.rxjava2.Observable
-
- tail() - Method in class hu.akarnokd.rxjava2.internal.util.LinkedArrayList
-
Returns the tail buffer segment or null if the list is empty.
- take(long) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- take(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- take(long) - Method in class hu.akarnokd.rxjava2.Observable
-
- take(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeFirst(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeFirst(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeLast(int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeLast(long, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeLast(long, long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeLast(long, long, TimeUnit, Scheduler, boolean, int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeLast(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeLast(long, TimeUnit, boolean) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeLast(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeLast(long, TimeUnit, Scheduler, boolean) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeLast(long, TimeUnit, Scheduler, boolean, int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeLast(int) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeLast(long, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeLast(long, long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeLast(long, long, TimeUnit, Scheduler, boolean, int) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeLast(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeLast(long, TimeUnit, boolean) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeLast(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeLast(long, TimeUnit, Scheduler, boolean) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeLast(long, TimeUnit, Scheduler, boolean, int) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeLastBuffer(int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeLastBuffer(int, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeLastBuffer(int, long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeLastBuffer(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeLastBuffer(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeLastBuffer(int) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeLastBuffer(int, long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeLastBuffer(int, long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeLastBuffer(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeLastBuffer(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeUntil(NbpObservable<U>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeUntil(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeUntil(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeUntil(Publisher<U>) - Method in class hu.akarnokd.rxjava2.Observable
-
- takeWhile(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- takeWhile(Predicate<? super T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- TerminalAtomicsHelper - Enum in hu.akarnokd.rxjava2.internal.util
-
Helper class to handle copy-on-write arrays plus terminal state for arbitrary references.
- terminate(AtomicReferenceFieldUpdater<T, U>, T, U, Consumer<? super U>) - Static method in enum hu.akarnokd.rxjava2.internal.util.TerminalAtomicsHelper
-
Atomically swaps in the terminalValue and calls the given callback if not already terminated.
- terminate(AtomicReference<U>, U, Consumer<? super U>) - Static method in enum hu.akarnokd.rxjava2.internal.util.TerminalAtomicsHelper
-
Atomically swaps in the terminalValue and calls the given callback if not already terminated.
- terminate(AtomicReferenceFieldUpdater<T, U>, T, U) - Static method in enum hu.akarnokd.rxjava2.internal.util.TerminalAtomicsHelper
-
Atomically swaps in the terminal value and returns the previous value.
- terminate(AtomicReference<U>, U) - Static method in enum hu.akarnokd.rxjava2.internal.util.TerminalAtomicsHelper
-
Atomically swaps in the terminal value and returns the previous value.
- TERMINATED - Static variable in class hu.akarnokd.rxjava2.internal.subscribers.BlockingSubscriber
-
- TERMINATED - Static variable in class hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpBlockingSubscriber
-
- test(T1, T2) - Method in interface hu.akarnokd.rxjava2.functions.BiPredicate
-
- test(T) - Method in interface hu.akarnokd.rxjava2.functions.Predicate
-
- test() - Static method in class hu.akarnokd.rxjava2.schedulers.Schedulers
-
- TestScheduler - Class in hu.akarnokd.rxjava2.schedulers
-
A special, non thread-safe scheduler for testing operators that require
a scheduler without introducing real concurrency and allows manually advancing
a virtual time.
- TestScheduler() - Constructor for class hu.akarnokd.rxjava2.schedulers.TestScheduler
-
- TestSubscriber<T> - Class in hu.akarnokd.rxjava2.subscribers
-
A subscriber that records events and allows making assertions about them.
- TestSubscriber() - Constructor for class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Constructs a non-forwarding TestSubscriber with an initial request value of Long.MAX_VALUE.
- TestSubscriber(Long) - Constructor for class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Constructs a non-forwarding TestSubscriber with the specified initial request value.
- TestSubscriber(Subscriber<? super T>) - Constructor for class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Constructs a forwarding TestSubscriber but leaves the requesting to the wrapped subscriber.
- TestSubscriber(Subscriber<? super T>, Long) - Constructor for class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Constructs a forwarding TestSubscriber with the specified initial request value.
- throttleFirst(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- throttleFirst(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- throttleFirst(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- throttleFirst(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- throttleLast(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- throttleLast(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- throttleLast(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- throttleLast(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- throttleWithTimeout(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- throttleWithTimeout(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- throttleWithTimeout(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- throttleWithTimeout(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- time() - Method in class hu.akarnokd.rxjava2.schedulers.Timed
-
- time(TimeUnit) - Method in class hu.akarnokd.rxjava2.schedulers.Timed
-
- Timed<T> - Class in hu.akarnokd.rxjava2.schedulers
-
Holds onto a value along with time information.
- Timed(T, long, TimeUnit) - Constructor for class hu.akarnokd.rxjava2.schedulers.Timed
-
- timeInterval() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timeInterval(Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timeInterval(TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timeInterval(TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timeInterval() - Method in class hu.akarnokd.rxjava2.Observable
-
- timeInterval(Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- timeInterval(TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- timeInterval(TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- timeout(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable that runs this Completable and emits a TimeoutException in case
this Completable doesn't complete within the given time.
- timeout(long, TimeUnit, Completable) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable that runs this Completable and switches to the other Completable
in case this Completable doesn't complete within the given time.
- timeout(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable that runs this Completable and emits a TimeoutException in case
this Completable doesn't complete within the given time while "waiting" on the specified
Scheduler.
- timeout(long, TimeUnit, Scheduler, Completable) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable that runs this Completable and switches to the other Completable
in case this Completable doesn't complete within the given time while "waiting" on
the specified scheduler.
- timeout(Function<? super T, ? extends NbpObservable<V>>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timeout(Function<? super T, ? extends NbpObservable<V>>, NbpObservable<? extends T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timeout(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timeout(long, TimeUnit, NbpObservable<? extends T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timeout(long, TimeUnit, NbpObservable<? extends T>, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timeout(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timeout(Supplier<? extends NbpObservable<U>>, Function<? super T, ? extends NbpObservable<V>>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timeout(Supplier<? extends NbpObservable<U>>, Function<? super T, ? extends NbpObservable<V>>, NbpObservable<? extends T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timeout(Function<? super T, ? extends Publisher<V>>) - Method in class hu.akarnokd.rxjava2.Observable
-
- timeout(Function<? super T, ? extends Publisher<V>>, Observable<? extends T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- timeout(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- timeout(long, TimeUnit, Observable<? extends T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- timeout(long, TimeUnit, Observable<? extends T>, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- timeout(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- timeout(Supplier<? extends Publisher<U>>, Function<? super T, ? extends Publisher<V>>) - Method in class hu.akarnokd.rxjava2.Observable
-
- timeout(Supplier<? extends Publisher<U>>, Function<? super T, ? extends Publisher<V>>, Publisher<? extends T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- timeout(long, TimeUnit) - Method in class hu.akarnokd.rxjava2.Single
-
- timeout(long, TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Single
-
- timeout(long, TimeUnit, Scheduler, Single<? extends T>) - Method in class hu.akarnokd.rxjava2.Single
-
- timeout(long, TimeUnit, Single<? extends T>) - Method in class hu.akarnokd.rxjava2.Single
-
- timeout0(long, TimeUnit, Scheduler, Completable) - Method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable that runs this Completable and optionally switches to the other Completable
in case this Completable doesn't complete within the given time while "waiting" on
the specified scheduler.
- timer(long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable instance that fires its onComplete event after the given delay ellapsed.
- timer(long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.rxjava2.Completable
-
Returns a Completable instance that fires its onComplete event after the given delay ellapsed
by using the supplied scheduler.
- timer(long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- timer(long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.rxjava2.NbpObservable
-
- timer(long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.Observable
-
- timer(long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.rxjava2.Observable
-
- timer(long, TimeUnit) - Static method in class hu.akarnokd.rxjava2.Single
-
- timer(long, TimeUnit, Scheduler) - Static method in class hu.akarnokd.rxjava2.Single
-
- timestamp() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timestamp(Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timestamp(TimeUnit) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timestamp(TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- timestamp() - Method in class hu.akarnokd.rxjava2.Observable
-
- timestamp(Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- timestamp(TimeUnit) - Method in class hu.akarnokd.rxjava2.Observable
-
- timestamp(TimeUnit, Scheduler) - Method in class hu.akarnokd.rxjava2.Observable
-
- to(Function<? super Completable, U>) - Method in class hu.akarnokd.rxjava2.Completable
-
Allows fluent conversion to another type via a function callback.
- to(Function<? super NbpObservable<T>, R>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- to(Function<? super Observable<T>, R>) - Method in class hu.akarnokd.rxjava2.Observable
-
- to(Function<? super Single<T>, R>) - Method in class hu.akarnokd.rxjava2.Single
-
- toArray() - Method in class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue
-
- toArray(E[]) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscExactArrayQueue
-
- toArray() - Method in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- toArray(E[]) - Method in class hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue
-
- toBlocking() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toBlocking() - Method in class hu.akarnokd.rxjava2.Observable
-
- toFlowable() - Method in class hu.akarnokd.rxjava2.Completable
-
Returns an Observable which when subscribed to subscribes to this Completable and
relays the terminal events to the subscriber.
- toFlowable() - Method in class hu.akarnokd.rxjava2.Single
-
- toFunction(BiFunction<? super T1, ? super T2, ? extends R>) - Static method in enum hu.akarnokd.rxjava2.internal.functions.Functions
-
- toFunction(Function3<T1, T2, T3, R>) - Static method in enum hu.akarnokd.rxjava2.internal.functions.Functions
-
- toFunction(Function4<T1, T2, T3, T4, R>) - Static method in enum hu.akarnokd.rxjava2.internal.functions.Functions
-
- toFunction(Function5<T1, T2, T3, T4, T5, R>) - Static method in enum hu.akarnokd.rxjava2.internal.functions.Functions
-
- toFunction(Function6<T1, T2, T3, T4, T5, T6, R>) - Static method in enum hu.akarnokd.rxjava2.internal.functions.Functions
-
- toFunction(Function7<T1, T2, T3, T4, T5, T6, T7, R>) - Static method in enum hu.akarnokd.rxjava2.internal.functions.Functions
-
- toFunction(Function8<T1, T2, T3, T4, T5, T6, T7, T8, R>) - Static method in enum hu.akarnokd.rxjava2.internal.functions.Functions
-
- toFunction(Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R>) - Static method in enum hu.akarnokd.rxjava2.internal.functions.Functions
-
- toFuture() - Method in class hu.akarnokd.rxjava2.observables.BlockingObservable
-
- toFuture() - Method in class hu.akarnokd.rxjava2.observables.nbp.NbpBlockingObservable
-
- toList() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toList(int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toList(Supplier<U>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toList() - Method in class hu.akarnokd.rxjava2.Observable
-
- toList(int) - Method in class hu.akarnokd.rxjava2.Observable
-
- toList(Supplier<U>) - Method in class hu.akarnokd.rxjava2.Observable
-
- toMap(Function<? super T, ? extends K>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toMap(Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toMap(Function<? super T, ? extends K>, Function<? super T, ? extends V>, Supplier<? extends Map<K, V>>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toMap(Function<? super T, ? extends K>) - Method in class hu.akarnokd.rxjava2.Observable
-
- toMap(Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Method in class hu.akarnokd.rxjava2.Observable
-
- toMap(Function<? super T, ? extends K>, Function<? super T, ? extends V>, Supplier<? extends Map<K, V>>) - Method in class hu.akarnokd.rxjava2.Observable
-
- toMultimap(Function<? super T, ? extends K>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toMultimap(Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toMultimap(Function<? super T, ? extends K>, Function<? super T, ? extends V>, Supplier<? extends Map<K, Collection<V>>>, Function<? super K, ? extends Collection<? super V>>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toMultimap(Function<? super T, ? extends K>, Function<? super T, ? extends V>, Supplier<Map<K, Collection<V>>>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toMultimap(Function<? super T, ? extends K>) - Method in class hu.akarnokd.rxjava2.Observable
-
- toMultimap(Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Method in class hu.akarnokd.rxjava2.Observable
-
- toMultimap(Function<? super T, ? extends K>, Function<? super T, ? extends V>, Supplier<? extends Map<K, Collection<V>>>, Function<? super K, ? extends Collection<? super V>>) - Method in class hu.akarnokd.rxjava2.Observable
-
- toMultimap(Function<? super T, ? extends K>, Function<? super T, ? extends V>, Supplier<Map<K, Collection<V>>>) - Method in class hu.akarnokd.rxjava2.Observable
-
- toNbpObservable() - Method in class hu.akarnokd.rxjava2.Completable
-
Returns an NbpObservable which when subscribed to subscribes to this Completable and
relays the terminal events to the subscriber.
- toNbpObservable() - Method in class hu.akarnokd.rxjava2.Observable
-
- ToNotificationSubscriber<T> - Class in hu.akarnokd.rxjava2.internal.subscribers
-
- ToNotificationSubscriber(Consumer<? super Try<Optional<Object>>>) - Constructor for class hu.akarnokd.rxjava2.internal.subscribers.ToNotificationSubscriber
-
- toObservable(BackpressureStrategy) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toSerialized() - Method in class hu.akarnokd.rxjava2.subjects.nbp.NbpSubject
-
Wraps this Subject and serializes the calls to the onSubscribe, onNext, onError and
onComplete methods, making them thread-safe.
- toSerialized() - Method in class hu.akarnokd.rxjava2.subjects.Subject
-
Wraps this Subject and serializes the calls to the onSubscribe, onNext, onError and
onComplete methods, making them thread-safe.
- toSingle(Supplier<? extends T>) - Method in class hu.akarnokd.rxjava2.Completable
-
Convers this Completable into a Single which when this Completable completes normally,
calls the given supplier and emits its returned value through onSuccess.
- toSingle() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toSingle() - Method in class hu.akarnokd.rxjava2.Observable
-
- toSingleDefault(T) - Method in class hu.akarnokd.rxjava2.Completable
-
Convers this Completable into a Single which when this Completable completes normally,
emits the given value through onSuccess.
- toSortedList() - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toSortedList(Comparator<? super T>) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toSortedList(Comparator<? super T>, int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toSortedList(int) - Method in class hu.akarnokd.rxjava2.NbpObservable
-
- toSortedList() - Method in class hu.akarnokd.rxjava2.Observable
-
- toSortedList(Comparator<? super T>) - Method in class hu.akarnokd.rxjava2.Observable
-
- toSortedList(Comparator<? super T>, int) - Method in class hu.akarnokd.rxjava2.Observable
-
- toSortedList(int) - Method in class hu.akarnokd.rxjava2.Observable
-
- toString() - Method in class hu.akarnokd.rxjava2.internal.schedulers.RxThreadFactory
-
- toString() - Method in enum hu.akarnokd.rxjava2.internal.subscriptions.EmptySubscription
-
- toString() - Method in class hu.akarnokd.rxjava2.internal.util.LinkedArrayList
-
- toString() - Method in class hu.akarnokd.rxjava2.schedulers.Timed
-
- toString() - Method in class hu.akarnokd.rxjava2.Try
-
- trampoline() - Static method in class hu.akarnokd.rxjava2.schedulers.Schedulers
-
- TrampolineScheduler - Class in hu.akarnokd.rxjava2.internal.schedulers
-
Schedules work on the current thread but does not execute immediately.
- triggerActions() - Method in class hu.akarnokd.rxjava2.schedulers.TestScheduler
-
Triggers any actions that have not yet been triggered and that are scheduled to be triggered at or
before this Scheduler's present time.
- Try<T> - Class in hu.akarnokd.rxjava2
-
Container for either a value of type T or a Throwable.
- validateDisposable(Disposable, Disposable) - Static method in enum hu.akarnokd.rxjava2.internal.subscriptions.SubscriptionHelper
-
Verifies that current is null, next is not null, otherwise signals errors
to the RxJavaPlugins and returns true
- validateRequest(long) - Static method in enum hu.akarnokd.rxjava2.internal.subscriptions.SubscriptionHelper
-
Validates that the n is positive.
- validateSubscription(Subscription, Subscription) - Static method in enum hu.akarnokd.rxjava2.internal.subscriptions.SubscriptionHelper
-
Verifies that current is null, next is not null, otherwise signals errors
to the RxJavaPlugins and returns true
- value() - Method in class hu.akarnokd.rxjava2.internal.operators.nbp.NbpObservableScalarSource
-
- value() - Method in class hu.akarnokd.rxjava2.internal.operators.ObservableScalarSource
-
- value() - Method in class hu.akarnokd.rxjava2.schedulers.Timed
-
- value() - Method in class hu.akarnokd.rxjava2.Try
-
Returns the value or null if the value is actually null or if this Try holds an error instead.
- valueCount() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Returns the number of onNext values received.
- valueCount() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Returns the number of onNext values received.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.annotations.BackpressureKind
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.annotations.SchedulerKind
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.BackpressureStrategy
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.disposables.EmptyDisposable
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.functions.Functions
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.functions.Objects
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.BlockingOperatorLatest
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.BlockingOperatorMostRecent
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.BlockingOperatorNext
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpBlockingOperatorLatest
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpBlockingOperatorMostRecent
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpBlockingOperatorNext
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorCount
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorDematerialize
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorIgnoreElements
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorMaterialize
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTakeLastOne
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.OperatorCount
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.OperatorDematerialize
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.OperatorIgnoreElements
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.OperatorMaterialize
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.OperatorOnBackpressureLatest
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.OperatorTakeLastOne
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.operators.PublisherEmptySource
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.schedulers.SchedulerPoolFactory
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.subscribers.CancelledSubscriber
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.subscribers.EmptySubscriber
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpCancelledSubscriber
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpEmptySubscriber
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.subscriptions.EmptySubscription
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.subscriptions.SubscriptionHelper
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.util.BackpressureHelper
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.util.Exceptions
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.util.NotificationLite
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.util.QueueDrainHelper
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum hu.akarnokd.rxjava2.internal.util.TerminalAtomicsHelper
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum hu.akarnokd.rxjava2.annotations.BackpressureKind
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.annotations.SchedulerKind
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.BackpressureStrategy
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.disposables.EmptyDisposable
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.functions.Functions
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.functions.Objects
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.BlockingOperatorLatest
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.BlockingOperatorMostRecent
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.BlockingOperatorNext
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpBlockingOperatorLatest
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpBlockingOperatorMostRecent
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpBlockingOperatorNext
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorCount
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorDematerialize
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorIgnoreElements
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorMaterialize
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.nbp.NbpOperatorTakeLastOne
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.OperatorCount
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.OperatorDematerialize
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.OperatorIgnoreElements
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.OperatorMaterialize
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.OperatorOnBackpressureLatest
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.OperatorTakeLastOne
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.operators.PublisherEmptySource
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.schedulers.SchedulerPoolFactory
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.subscribers.CancelledSubscriber
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.subscribers.EmptySubscriber
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpCancelledSubscriber
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.subscribers.nbp.NbpEmptySubscriber
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.subscriptions.EmptySubscription
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.subscriptions.SubscriptionHelper
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.util.BackpressureHelper
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.util.Exceptions
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.util.NotificationLite
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.util.QueueDrainHelper
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum hu.akarnokd.rxjava2.internal.util.TerminalAtomicsHelper
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Method in class hu.akarnokd.rxjava2.subscribers.nbp.NbpTestSubscriber
-
Returns a shared list of received onNext values.
- values() - Method in class hu.akarnokd.rxjava2.subscribers.TestSubscriber
-
Returns a shared list of received onNext values.