io.reactivex.rxjava3.core

Interface FlowableSubscriber<T>

Type Parameters:

T - the value type

All Superinterfaces:

Subscriber<T>

All Known Subinterfaces:

ConditionalSubscriber<T>

All Known Implementing Classes:

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

public interface FlowableSubscriber<T>
extends Subscriber<T>

Represents a Reactive-Streams inspired 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

Since:

2.2

Method Summary

Modifier and Type	Method and Description
void	onSubscribe(@NonNull 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 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 Subscriber<T>