T- the value type
public interface FlowableSubscriber<T> extends Subscriber<T>
Subscriberthat 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
void onSubscribe(@NonNull @NonNull Subscription s)
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