Interface FlowableSubscriber<T>

    • 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 in Subscriber.onNext(Object) is established before calling Subscription.request(long).
      • Methods inherited from interface org.reactivestreams.Subscriber

        onComplete, onError, onNext
    • Method Detail

      • 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>