T
- the value typepublic interface FlowableSubscriber<T>
extends org.reactivestreams.Subscriber<T>
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
Modifier and Type | Method and 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) . |
void onSubscribe(@NonNull @NonNull org.reactivestreams.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 onNext
.
onSubscribe
in interface org.reactivestreams.Subscriber<T>