FlowableSubscriber

implements Subscriber<T>

io.reactivex.FlowableSubscriber<T>

Known Indirect Subclasses

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

AsyncProcessor<T>	Processor that emits the very last value followed by a completion event or the received error to Subscribers.
BehaviorProcessor<T>	Processor that emits the most recent item it has observed and all subsequent observed items to each subscribed Subscriber.
DefaultSubscriber<T>	Abstract base implementation of a org.reactivestreams.Subscriber Subscriber with support for requesting via `request(long)`, cancelling via via `cancel()` (both synchronously) and calls `onStart()` when the subscription happens.
DisposableSubscriber<T>	An abstract Subscriber that allows asynchronous, external cancellation by implementing Disposable.
FlowableProcessor<T>	Represents a Subscriber and a Flowable (Publisher) at the same time, allowing multicasting events from a single source to multiple child Subscribers.
PublishProcessor<T>	Processor that multicasts all subsequently observed items to its current Subscribers.
ReplayProcessor<T>	Replays events to Subscribers.
ResourceSubscriber<T>	An abstract Subscriber that allows asynchronous cancellation of its subscription and associated resources.
SafeSubscriber<T>	Wraps another Subscriber and ensures all onXXX methods conform the protocol (except the requirement for serialized access).
SerializedSubscriber<T>	Serializes access to the onNext, onError and onComplete methods of another Subscriber.
TestSubscriber<T>	A subscriber that records events and allows making assertions about them.
UnicastProcessor<T>	Processor that allows only a single Subscriber to subscribe to it during its lifetime.

Class Overview

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

Summary

Public Methods
abstract void	onSubscribe(Subscription s) Implementors of this method should make sure everything that needs to be visible in `onNext(Object)` is established before calling `request(long)`.

[Expand]

Inherited Methods

From interface org.reactivestreams.Subscriber

Public Methods

public abstract void onSubscribe (Subscription s)

Implementors of this method should make sure everything that needs to be visible in onNext(Object) is established before calling request(long). In practice this means no initialization should happen after the request() call and additional behavior is thread safe in respect to onNext.

Interfaces

Classes

Enums

FlowableSubscriber

Class Overview

Summary

Public Methods

public abstract void onSubscribe (Subscription s)