io.reactivex

Interface FlowableSubscriber<T>

Type Parameters:

T - the value type

All Superinterfaces:

org.reactivestreams.Subscriber<T>

All Known Implementing Classes:

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

public interface FlowableSubscriber<T>
extends org.reactivestreams.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.

Since:

2.0.7 - experimental

Method Summary

Methods

Modifier and Type	Method and Description
void	onSubscribe(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).

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext

Method Detail

onSubscribe

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). 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 org.reactivestreams.Subscriber<T>