Class SafeSubscriber<T>

java.lang.Object

io.reactivex.rxjava4.subscribers.SafeSubscriber<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

FlowableSubscriber<T>, Flow.Subscriber<T>, Flow.Subscription

public final class SafeSubscriber<@NonNull T>
extends Object
implements FlowableSubscriber<T>, Flow.Subscription

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

Constructor Summary

Constructors

Constructor	Description
SafeSubscriber(@NonNull Flow.Subscriber<? super @NonNull T> downstream)	Constructs a SafeSubscriber by wrapping the given actual Flow.Subscriber.

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	onComplete()
void	onError(@NonNull Throwable t)
void	onNext(@NonNull T t)
void	onSubscribe(@NonNull Flow.Subscription s)	Implementors of this method should make sure everything that needs to be visible in Flow.Subscriber.onNext(Object) is established before calling Flow.Subscription.request(long).
void	request(long n)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SafeSubscriber

public SafeSubscriber(@NonNull
 @NonNull Flow.Subscriber<? super @NonNull T> downstream)

Constructs a SafeSubscriber by wrapping the given actual Flow.Subscriber.

Parameters:

downstream - the actual Subscriber to wrap, not null (not validated)

Method Details

onSubscribe

public void onSubscribe(@NonNull
 @NonNull Flow.Subscription s)

Description copied from interface: FlowableSubscriber

Implementors of this method should make sure everything that needs to be visible in Flow.Subscriber.onNext(Object) is established before calling Flow.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 Flow.Subscriber<T>

Specified by:

onSubscribe in interface FlowableSubscriber<T>

onNext

public void onNext(@NonNull
 @NonNull T t)

Specified by:

onNext in interface Flow.Subscriber<T>

onError

public void onError(@NonNull
 @NonNull Throwable t)

Specified by:

onError in interface Flow.Subscriber<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface Flow.Subscriber<T>

request

public void request(long n)

Specified by:

request in interface Flow.Subscription

cancel

public void cancel()

Specified by:

cancel in interface Flow.Subscription