Package io.reactivex.rxjava3.core
Interface FlowableSubscriber<T>
-
- Type Parameters:
T
- the value type
- All Superinterfaces:
org.reactivestreams.Subscriber<T>
- All Known Subinterfaces:
ConditionalSubscriber<T>
- All Known Implementing Classes:
AbstractBackpressureThrottlingSubscriber
,AsyncProcessor
,BasicFuseableConditionalSubscriber
,BasicFuseableSubscriber
,BehaviorProcessor
,BlockingBaseSubscriber
,BlockingFirstSubscriber
,BlockingFlowableIterable.BlockingFlowableIterator
,BlockingFlowableLatest.LatestSubscriberIterator
,BlockingFlowableMostRecent.MostRecentSubscriber
,BlockingFlowableNext.NextSubscriber
,BlockingLastSubscriber
,BlockingSubscriber
,BoundedSubscriber
,CompletableAndThenPublisher.AndThenPublisherSubscriber
,CompletableConcat.CompletableConcatSubscriber
,CompletableFromPublisher.FromPublisherSubscriber
,CompletableMerge.CompletableMergeSubscriber
,ConcatMapXMainSubscriber
,DefaultSubscriber
,DeferredScalarSubscriber
,DisposableAutoReleaseSubscriber
,DisposableSubscriber
,EmptyComponent
,FlowableAll.AllSubscriber
,FlowableAllSingle.AllSubscriber
,FlowableAmb.AmbInnerSubscriber
,FlowableAny.AnySubscriber
,FlowableAnySingle.AnySubscriber
,FlowableBuffer.PublisherBufferExactSubscriber
,FlowableBuffer.PublisherBufferOverlappingSubscriber
,FlowableBuffer.PublisherBufferSkipSubscriber
,FlowableBufferBoundary.BufferBoundarySubscriber
,FlowableBufferBoundary.BufferBoundarySubscriber.BufferOpenSubscriber
,FlowableBufferBoundary.BufferCloseSubscriber
,FlowableBufferExactBoundary.BufferBoundarySubscriber
,FlowableBufferExactBoundary.BufferExactBoundarySubscriber
,FlowableBufferTimed.BufferExactBoundedSubscriber
,FlowableBufferTimed.BufferExactUnboundedSubscriber
,FlowableBufferTimed.BufferSkipBoundedSubscriber
,FlowableCache
,FlowableCollect.CollectSubscriber
,FlowableCollectSingle.CollectSubscriber
,FlowableCollectWithCollector.CollectorSubscriber
,FlowableCollectWithCollectorSingle.CollectorSingleObserver
,FlowableCombineLatest.CombineLatestInnerSubscriber
,FlowableConcatArray.ConcatArraySubscriber
,FlowableConcatMap.BaseConcatMapSubscriber
,FlowableConcatMap.ConcatMapDelayed
,FlowableConcatMap.ConcatMapImmediate
,FlowableConcatMap.ConcatMapInner
,FlowableConcatMapCompletable.ConcatMapCompletableObserver
,FlowableConcatMapEager.ConcatMapEagerDelayErrorSubscriber
,FlowableConcatMapMaybe.ConcatMapMaybeSubscriber
,FlowableConcatMapScheduler.BaseConcatMapSubscriber
,FlowableConcatMapScheduler.ConcatMapDelayed
,FlowableConcatMapScheduler.ConcatMapImmediate
,FlowableConcatMapSingle.ConcatMapSingleSubscriber
,FlowableConcatWithCompletable.ConcatWithSubscriber
,FlowableConcatWithMaybe.ConcatWithSubscriber
,FlowableConcatWithSingle.ConcatWithSubscriber
,FlowableCount.CountSubscriber
,FlowableCountSingle.CountSubscriber
,FlowableDebounce.DebounceSubscriber
,FlowableDebounce.DebounceSubscriber.DebounceInnerSubscriber
,FlowableDebounceTimed.DebounceTimedSubscriber
,FlowableDelay.DelaySubscriber
,FlowableDelaySubscriptionOther.MainSubscriber
,FlowableDelaySubscriptionOther.MainSubscriber.OtherSubscriber
,FlowableDematerialize.DematerializeSubscriber
,FlowableDetach.DetachSubscriber
,FlowableDistinct.DistinctSubscriber
,FlowableDistinctUntilChanged.DistinctUntilChangedConditionalSubscriber
,FlowableDistinctUntilChanged.DistinctUntilChangedSubscriber
,FlowableDoAfterNext.DoAfterConditionalSubscriber
,FlowableDoAfterNext.DoAfterSubscriber
,FlowableDoFinally.DoFinallyConditionalSubscriber
,FlowableDoFinally.DoFinallySubscriber
,FlowableDoOnEach.DoOnEachConditionalSubscriber
,FlowableDoOnEach.DoOnEachSubscriber
,FlowableDoOnLifecycle.SubscriptionLambdaSubscriber
,FlowableElementAt.ElementAtSubscriber
,FlowableElementAtMaybe.ElementAtSubscriber
,FlowableElementAtSingle.ElementAtSubscriber
,FlowableFilter.FilterConditionalSubscriber
,FlowableFilter.FilterSubscriber
,FlowableFirstStageSubscriber
,FlowableFlatMap.InnerSubscriber
,FlowableFlatMap.MergeSubscriber
,FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber
,FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber
,FlowableFlatMapMaybe.FlatMapMaybeSubscriber
,FlowableFlatMapSingle.FlatMapSingleSubscriber
,FlowableFlatMapStream.FlatMapStreamSubscriber
,FlowableFlattenIterable.FlattenIterableSubscriber
,FlowableGroupBy.GroupBySubscriber
,FlowableGroupJoin.LeftRightEndSubscriber
,FlowableGroupJoin.LeftRightSubscriber
,FlowableHide.HideSubscriber
,FlowableIgnoreElements.IgnoreElementsSubscriber
,FlowableIgnoreElementsCompletable.IgnoreElementsSubscriber
,FlowableLastMaybe.LastSubscriber
,FlowableLastSingle.LastSubscriber
,FlowableLastStageSubscriber
,FlowableMap.MapConditionalSubscriber
,FlowableMap.MapSubscriber
,FlowableMapNotification.MapNotificationSubscriber
,FlowableMapOptional.MapOptionalConditionalSubscriber
,FlowableMapOptional.MapOptionalSubscriber
,FlowableMaterialize.MaterializeSubscriber
,FlowableMergeWithCompletable.MergeWithSubscriber
,FlowableMergeWithMaybe.MergeWithObserver
,FlowableMergeWithSingle.MergeWithObserver
,FlowableObserveOn.BaseObserveOnSubscriber
,FlowableObserveOn.ObserveOnConditionalSubscriber
,FlowableObserveOn.ObserveOnSubscriber
,FlowableOnBackpressureBuffer.BackpressureBufferSubscriber
,FlowableOnBackpressureBufferStrategy.OnBackpressureBufferStrategySubscriber
,FlowableOnBackpressureDrop.BackpressureDropSubscriber
,FlowableOnBackpressureError.BackpressureErrorSubscriber
,FlowableOnBackpressureLatest.BackpressureLatestSubscriber
,FlowableOnBackpressureReduce.BackpressureReduceSubscriber
,FlowableOnBackpressureReduceWith.BackpressureReduceWithSubscriber
,FlowableOnErrorComplete.OnErrorCompleteSubscriber
,FlowableOnErrorNext.OnErrorNextSubscriber
,FlowableOnErrorReturn.OnErrorReturnSubscriber
,FlowableProcessor
,FlowablePublish.PublishConnection
,FlowablePublishMulticast.MulticastProcessor
,FlowablePublishMulticast.OutputCanceller
,FlowableReduce.ReduceSubscriber
,FlowableReduceMaybe.ReduceSubscriber
,FlowableReduceSeedSingle.ReduceSeedObserver
,FlowableRefCount.RefCountSubscriber
,FlowableRepeat.RepeatSubscriber
,FlowableRepeatUntil.RepeatSubscriber
,FlowableRepeatWhen.RepeatWhenSubscriber
,FlowableRepeatWhen.WhenReceiver
,FlowableRepeatWhen.WhenSourceSubscriber
,FlowableReplay.ReplaySubscriber
,FlowableRetryBiPredicate.RetryBiSubscriber
,FlowableRetryPredicate.RetrySubscriber
,FlowableRetryWhen.RetryWhenSubscriber
,FlowableSamplePublisher.SampleMainEmitLast
,FlowableSamplePublisher.SampleMainNoLast
,FlowableSamplePublisher.SamplePublisherSubscriber
,FlowableSamplePublisher.SamplerSubscriber
,FlowableSampleTimed.SampleTimedEmitLast
,FlowableSampleTimed.SampleTimedNoLast
,FlowableSampleTimed.SampleTimedSubscriber
,FlowableScan.ScanSubscriber
,FlowableScanSeed.ScanSeedSubscriber
,FlowableSequenceEqual.EqualSubscriber
,FlowableSingle.SingleElementSubscriber
,FlowableSingleMaybe.SingleElementSubscriber
,FlowableSingleSingle.SingleElementSubscriber
,FlowableSingleStageSubscriber
,FlowableSkip.SkipSubscriber
,FlowableSkipLast.SkipLastSubscriber
,FlowableSkipLastTimed.SkipLastTimedSubscriber
,FlowableSkipUntil.SkipUntilMainSubscriber
,FlowableSkipUntil.SkipUntilMainSubscriber.OtherSubscriber
,FlowableSkipWhile.SkipWhileSubscriber
,FlowableStageSubscriber
,FlowableSubscribeOn.SubscribeOnSubscriber
,FlowableSwitchIfEmpty.SwitchIfEmptySubscriber
,FlowableSwitchMap.SwitchMapInnerSubscriber
,FlowableSwitchMap.SwitchMapSubscriber
,FlowableSwitchMapCompletable.SwitchMapCompletableObserver
,FlowableSwitchMapMaybe.SwitchMapMaybeSubscriber
,FlowableSwitchMapSingle.SwitchMapSingleSubscriber
,FlowableTake.TakeSubscriber
,FlowableTakeLast.TakeLastSubscriber
,FlowableTakeLastOne.TakeLastOneSubscriber
,FlowableTakeLastTimed.TakeLastTimedSubscriber
,FlowableTakeUntil.TakeUntilMainSubscriber
,FlowableTakeUntil.TakeUntilMainSubscriber.OtherSubscriber
,FlowableTakeUntilPredicate.InnerSubscriber
,FlowableTakeWhile.TakeWhileSubscriber
,FlowableThrottleFirstTimed.DebounceTimedSubscriber
,FlowableThrottleLatest.ThrottleLatestSubscriber
,FlowableTimeInterval.TimeIntervalSubscriber
,FlowableTimeout.TimeoutConsumer
,FlowableTimeout.TimeoutFallbackSubscriber
,FlowableTimeout.TimeoutSubscriber
,FlowableTimeoutTimed.FallbackSubscriber
,FlowableTimeoutTimed.TimeoutFallbackSubscriber
,FlowableTimeoutTimed.TimeoutSubscriber
,FlowableToList.ToListSubscriber
,FlowableToListSingle.ToListSubscriber
,FlowableUnsubscribeOn.UnsubscribeSubscriber
,FlowableUsing.UsingSubscriber
,FlowableWindow.WindowExactSubscriber
,FlowableWindow.WindowOverlapSubscriber
,FlowableWindow.WindowSkipSubscriber
,FlowableWindowBoundary.WindowBoundaryInnerSubscriber
,FlowableWindowBoundary.WindowBoundaryMainSubscriber
,FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber
,FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowEndSubscriberIntercept
,FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowStartSubscriber
,FlowableWindowTimed.AbstractWindowSubscriber
,FlowableWindowTimed.WindowExactBoundedSubscriber
,FlowableWindowTimed.WindowExactUnboundedSubscriber
,FlowableWindowTimed.WindowSkipSubscriber
,FlowableWithLatestFrom.FlowableWithLatestSubscriber
,FlowableWithLatestFrom.WithLatestFromSubscriber
,FlowableWithLatestFromMany.WithLatestFromSubscriber
,FlowableWithLatestFromMany.WithLatestInnerSubscriber
,FlowableZip.ZipSubscriber
,FlowableZipIterable.ZipIterableSubscriber
,ForEachWhileSubscriber
,FutureSubscriber
,InnerQueuedSubscriber
,LambdaSubscriber
,MaybeDelayOtherPublisher.OtherSubscriber
,MaybeDelaySubscriptionOtherPublisher.OtherSubscriber
,MaybeFlatMapPublisher.FlatMapPublisherSubscriber
,MaybeTakeUntilPublisher.TakeUntilMainMaybeObserver.TakeUntilOtherMaybeObserver
,MaybeTimeoutPublisher.TimeoutOtherMaybeObserver
,MulticastProcessor
,ObservableFromPublisher.PublisherSubscriber
,ParallelCollect.ParallelCollectSubscriber
,ParallelCollector.ParallelCollectorInnerSubscriber
,ParallelDoOnNextTry.ParallelDoOnNextConditionalSubscriber
,ParallelDoOnNextTry.ParallelDoOnNextSubscriber
,ParallelFilter.BaseFilterSubscriber
,ParallelFilter.ParallelFilterConditionalSubscriber
,ParallelFilter.ParallelFilterSubscriber
,ParallelFilterTry.BaseFilterSubscriber
,ParallelFilterTry.ParallelFilterConditionalSubscriber
,ParallelFilterTry.ParallelFilterSubscriber
,ParallelFromPublisher.ParallelDispatcher
,ParallelJoin.JoinInnerSubscriber
,ParallelMap.ParallelMapConditionalSubscriber
,ParallelMap.ParallelMapSubscriber
,ParallelMapOptional.ParallelMapConditionalSubscriber
,ParallelMapOptional.ParallelMapSubscriber
,ParallelMapTry.ParallelMapTryConditionalSubscriber
,ParallelMapTry.ParallelMapTrySubscriber
,ParallelMapTryOptional.ParallelMapTryConditionalSubscriber
,ParallelMapTryOptional.ParallelMapTrySubscriber
,ParallelPeek.ParallelPeekSubscriber
,ParallelReduce.ParallelReduceSubscriber
,ParallelReduceFull.ParallelReduceFullInnerSubscriber
,ParallelRunOn.BaseRunOnSubscriber
,ParallelRunOn.RunOnConditionalSubscriber
,ParallelRunOn.RunOnSubscriber
,ParallelSortedJoin.SortedJoinInnerSubscriber
,PublishProcessor
,QueueDrainSubscriber
,ReplayProcessor
,ResourceSubscriber
,SafeSubscriber
,SerializedProcessor
,SerializedSubscriber
,SingleDelayWithPublisher.OtherSubscriber
,SingleFlatMapPublisher.SingleFlatMapPublisherObserver
,SingleFromPublisher.ToSingleObserver
,SinglePostCompleteSubscriber
,SingleTakeUntil.TakeUntilOtherSubscriber
,StrictSubscriber
,SubscriberResourceWrapper
,TestSubscriber
,TestSubscriber.EmptySubscriber
,UnicastProcessor
public interface FlowableSubscriber<@NonNull T> extends org.reactivestreams.Subscriber<T>
Represents a Reactive-Streams inspiredSubscriber
that is RxJava 3 only and weakens the Reactive Streams rules §1.3 and §3.9 of the specification for gaining performance.History: 2.0.7 - experimental; 2.1 - beta
- Since:
- 2.2
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
onSubscribe(@NonNull org.reactivestreams.Subscription s)
Implementors of this method should make sure everything that needs to be visible inSubscriber.onNext(Object)
is established before callingSubscription.request(long)
.
-
-
-
Method Detail
-
onSubscribe
void onSubscribe(@NonNull @NonNull org.reactivestreams.Subscription s)
Implementors of this method should make sure everything that needs to be visible inSubscriber.onNext(Object)
is established before callingSubscription.request(long)
. In practice this means no initialization should happen after therequest()
call and additional behavior is thread safe in respect toonNext
.- Specified by:
onSubscribe
in interfaceorg.reactivestreams.Subscriber<T>
-
-