io.reactivex

Interface FlowableSubscriber<T>

Type Parameters:

T - the value type

All Superinterfaces:

Subscriber<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 2 only and weakens 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(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
                 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>