Interface FlowableSubscriber<T>

Type Parameters:

T - the value type

All Superinterfaces:

Flow.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<@NonNull T>
extends Flow.Subscriber<T>

Represents a Reactive-Streams inspired Flow.Subscriber that is RxJava 4 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	Description
void	onSubscribe(@NonNull Flow.Subscription s)	Implementors of this method should make sure everything that needs to be visible in Flow.Subscriber.onNext(Object) is established before calling Flow.Subscription.request(long).

Methods inherited from interface Flow.Subscriber

onComplete, onError, onNext

Method Details

onSubscribe

void onSubscribe(@NonNull
 @NonNull Flow.Subscription s)

Implementors of this method should make sure everything that needs to be visible in Flow.Subscriber.onNext(Object) is established before calling Flow.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 Flow.Subscriber<T>