Movatterモバイル変換

Type Parameters:

T - the value type

All Superinterfaces:

Subscriber<T>

All Known Implementing Classes:

AsyncProcessor,BehaviorProcessor,DefaultSubscriber,DisposableSubscriber,FlowableProcessor,MulticastProcessor,PublishProcessor,ReplayProcessor,ResourceSubscriber,SafeSubscriber,SerializedSubscriber,TestSubscriber,UnicastProcessor

public interfaceFlowableSubscriber<T>extendsSubscriber<T>

Since:

2.2

• Method Summary

  All Methods Instance Methods Abstract Methods 

  Modifier and Type	Method and Description
  void	onSubscribe(Subscription s) Implementors of this method should make sure everything that needs to be visible inSubscriber.onNext(Object) is established before callingSubscription.request(long).

  • Methods inherited from interface org.reactivestreams.Subscriber

    onComplete,onError,onNext

• Method Detail

  • onSubscribe

    void onSubscribe(@NonNullSubscription 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 interface Subscriber<T>