RxJava 2 2.2.21 · io.reactivex.FlowableSubscriber

Method Summary

Modifier and Type	Method and Description
public void	onSubscribe(Subscription the `Subscription` that allows requesting data via `Subscription#request(long)` s) Redeclares org.reactivestreams.Subscriber.onSubscribe. Implementors of this method should make sure everything that needs to be visible in `onNext(Object)` is established before calling `Subscription#request(long)`.

Inherited from org.reactivestreams.Subscriber:: onComplete onError onNext

Method Detail

onSubscribe back to summary

onSubscribe	back to summary
public void onSubscribe(Subscription s) Redeclares org.reactivestreams.Subscriber.onSubscribe. Doc from org.reactivestreams.Subscriber.onSubscribe. Implementors of this method should make sure everything that needs to be visible in `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`. Invoked after calling `Publisher#subscribe(Subscriber)`. No data will start flowing until `Subscription#request(long)` is invoked. It is the responsibility of this `Subscriber` instance to call `Subscription#request(long)` whenever more data is wanted. The `Publisher` will send notifications only in response to `Subscription#request(long)`. Parameters s:Subscription the `Subscription` that allows requesting data via `Subscription#request(long)` Annotations @Override

public void onSubscribe(Subscription s)

Redeclares org.reactivestreams.Subscriber.onSubscribe.

Doc from org.reactivestreams.Subscriber.onSubscribe.

Implementors of this method should make sure everything that needs to be visible in 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. Invoked after calling Publisher#subscribe(Subscriber).

No data will start flowing until Subscription#request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription#request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription#request(long).

Parameters

s:Subscription: the Subscription that allows requesting data via Subscription#request(long)

Annotations

@Override

public Interface FlowableSubscriber<T>

Method Summary

Method Detail