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 inspired Subscriber 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

    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 in Subscriber.onNext(Object) is established before calling Subscription.request(long).

    Methods inherited from interface org.reactivestreams.Subscriber

    onComplete, onError, onNext

  • Method Details

    • onSubscribe

      void onSubscribe(@NonNull @NonNull org.reactivestreams.Subscription s)
      Implementors of this method should make sure everything that needs to be visible in Subscriber.onNext(Object) is established before calling Subscription.request(long). In practice this means no initialization should happen after the request() call and additional behavior is thread safe in respect to onNext.
      Specified by:
      onSubscribe in interface org.reactivestreams.Subscriber<T>