public final class

SafeSubscriber

extends Object
implements FlowableSubscriber<T> Subscription
java.lang.Object
   ↳ io.reactivex.subscribers.SafeSubscriber<T>

Class Overview

Wraps another Subscriber and ensures all onXXX methods conform the protocol (except the requirement for serialized access).

Summary

Public Constructors
SafeSubscriber(Subscriber<? super T> actual)
Constructs a SafeSubscriber by wrapping the given actual Subscriber.
Public Methods
void cancel()
void onComplete()
void onError(Throwable t)
void onNext(T t)
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).
void request(long n)
[Expand]
Inherited Methods
From class java.lang.Object
From interface io.reactivex.FlowableSubscriber
From interface org.reactivestreams.Subscriber
From interface org.reactivestreams.Subscription

Public Constructors

public SafeSubscriber (Subscriber<? super T> actual)

Constructs a SafeSubscriber by wrapping the given actual Subscriber.

Parameters
actual the actual Subscriber to wrap, not null (not validated)

Public Methods

public void cancel ()

public void onComplete ()

public void onError (Throwable t)

public void onNext (T t)

public 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.

public void request (long n)