Interface FlowableSubscriber<T>

Type Parameters:
T - the value type
All Superinterfaces:
org.reactivestreams.Subscriber<T>
All Known Subinterfaces:
ConditionalSubscriber<T>
All Known Implementing Classes:
AsyncProcessor, BasicFuseableConditionalSubscriber, BasicFuseableSubscriber, BehaviorProcessor, BlockingBaseSubscriber, BlockingFirstSubscriber, BlockingLastSubscriber, BlockingSubscriber, BoundedSubscriber, ConcatMapXMainSubscriber, DefaultSubscriber, DeferredScalarSubscriber, DisposableAutoReleaseSubscriber, DisposableSubscriber, EmptyComponent, FlowableCache, FlowableFirstStageSubscriber, FlowableGroupBy.GroupBySubscriber, FlowableLastStageSubscriber, FlowableOnErrorComplete.OnErrorCompleteSubscriber, FlowableProcessor, FlowableSingleStageSubscriber, ForEachWhileSubscriber, FutureSubscriber, InnerQueuedSubscriber, LambdaSubscriber, MulticastProcessor, PublishProcessor, QueueDrainSubscriber, ReplayProcessor, ResourceSubscriber, SafeSubscriber, SerializedSubscriber, SinglePostCompleteSubscriber, StrictSubscriber, SubscriberResourceWrapper, TestSubscriber, 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>