io.reactivex

Interface FlowableSubscriber

Type Parameters:

T - the value type

All Superinterfaces:

Subscriber

All Known Implementing Classes:

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

public interface FlowableSubscriber
extends Subscriber

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>