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 SubscriptionSingle.subscribe(SingleSubscriber<? super T> te) Subscribes to a Single and provides aSingleSubscriberthat 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 voidExceptions.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 classFields 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.actualMethods in rx.internal.operators with parameters of type SingleSubscriberModifier and TypeMethodDescriptionvoidOnSubscribeOnAssemblySingle.call(SingleSubscriber<? super T> t) voidOnSubscribeSingle.call(SingleSubscriber<? super T> child) voidSingleDoAfterTerminate.call(SingleSubscriber<? super T> t) voidSingleOnSubscribeDelaySubscriptionOther.call(SingleSubscriber<? super T> subscriber) voidSingleOnSubscribeMap.call(SingleSubscriber<? super R> o) voidSingleOnSubscribeUsing.call(SingleSubscriber<? super T> child) voidSingleOperatorOnErrorResumeNext.call(SingleSubscriber<? super T> child) (package private) voidSingleOnSubscribeUsing.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.subscriberMethods in rx.internal.util with parameters of type SingleSubscriberModifier and TypeMethodDescriptionvoidScalarSynchronousSingle.DirectScheduledEmission.call(SingleSubscriber<? super T> singleSubscriber) voidScalarSynchronousSingle.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)