Uses of Class
rx.SingleSubscriber
Packages that use SingleSubscriber
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
Exception handling utilities, safe subscriber exception classes,
lifecycle exception classes.
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Uses of SingleSubscriber in rx
Methods in rx with parameters of type SingleSubscriberModifier and TypeMethodDescriptionfinal Subscription
Single.subscribe
(SingleSubscriber<? super T> te) Subscribes to a Single and provides aSingleSubscriber
that implements functions to handle the item the Single emits or any error notification it issues. -
Uses of SingleSubscriber in rx.exceptions
Methods in rx.exceptions with parameters of type SingleSubscriberModifier and TypeMethodDescriptionstatic void
Exceptions.throwOrReport
(Throwable throwable, SingleSubscriber<?> subscriber) Forwards a fatal exception or reports it to the given Observer. -
Uses of SingleSubscriber in rx.internal.operators
Subclasses of SingleSubscriber in rx.internal.operatorsModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
Fields in rx.internal.operators declared as SingleSubscriberModifier and TypeFieldDescription(package private) final SingleSubscriber
<? super T> OnSubscribeOnAssemblySingle.OnAssemblySingleSubscriber.actual
(package private) final SingleSubscriber
<? super T> SingleDoAfterTerminate.SingleDoAfterTerminateSubscriber.actual
(package private) final SingleSubscriber
<? super R> SingleOnSubscribeMap.MapSubscriber.actual
Methods in rx.internal.operators with parameters of type SingleSubscriberModifier and TypeMethodDescriptionvoid
OnSubscribeOnAssemblySingle.call
(SingleSubscriber<? super T> t) void
OnSubscribeSingle.call
(SingleSubscriber<? super T> child) void
SingleDoAfterTerminate.call
(SingleSubscriber<? super T> t) void
SingleOnSubscribeDelaySubscriptionOther.call
(SingleSubscriber<? super T> subscriber) void
SingleOnSubscribeMap.call
(SingleSubscriber<? super R> o) void
SingleOnSubscribeUsing.call
(SingleSubscriber<? super T> child) void
SingleOperatorOnErrorResumeNext.call
(SingleSubscriber<? super T> child) (package private) void
SingleOnSubscribeUsing.handleSubscriptionTimeError
(SingleSubscriber<? super T> t, Resource resource, Throwable ex) Constructors in rx.internal.operators with parameters of type SingleSubscriberModifierConstructorDescriptionMapSubscriber
(SingleSubscriber<? super R> actual, Func1<? super T, ? extends R> mapper) OnAssemblySingleSubscriber
(SingleSubscriber<? super T> actual, String stacktrace) SingleDoAfterTerminateSubscriber
(SingleSubscriber<? super T> actual, Action0 action) -
Uses of SingleSubscriber in rx.internal.util
Fields in rx.internal.util declared as SingleSubscriberModifier and TypeFieldDescriptionprivate final SingleSubscriber
<? super T> ScalarSynchronousSingle.ScalarSynchronousSingleAction.subscriber
Methods in rx.internal.util with parameters of type SingleSubscriberModifier and TypeMethodDescriptionvoid
ScalarSynchronousSingle.DirectScheduledEmission.call
(SingleSubscriber<? super T> singleSubscriber) void
ScalarSynchronousSingle.NormalScheduledEmission.call
(SingleSubscriber<? super T> singleSubscriber) Constructors in rx.internal.util with parameters of type SingleSubscriberModifierConstructorDescription(package private)
ScalarSynchronousSingleAction
(SingleSubscriber<? super T> subscriber, T value)