Uses of Class
rx.SingleSubscriber
-
Packages that use SingleSubscriber Package Description rx Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.rx.exceptions Exception handling utilities, safe subscriber exception classes, lifecycle exception classes.rx.internal.operators Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.rx.internal.util -
-
Uses of SingleSubscriber in rx
Methods in rx with parameters of type SingleSubscriber Modifier and Type Method Description 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 SingleSubscriber Modifier and Type Method Description static void
Exceptions. throwOrReport(java.lang.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.operators Modifier and Type Class Description (package private) static class
OnSubscribeOnAssemblySingle.OnAssemblySingleSubscriber<T>
(package private) static class
SingleDoAfterTerminate.SingleDoAfterTerminateSubscriber<T>
(package private) static class
SingleOnSubscribeMap.MapSubscriber<T,R>
Fields in rx.internal.operators declared as SingleSubscriber Modifier and Type Field Description (package private) SingleSubscriber<? super T>
OnSubscribeOnAssemblySingle.OnAssemblySingleSubscriber. actual
(package private) SingleSubscriber<? super T>
SingleDoAfterTerminate.SingleDoAfterTerminateSubscriber. actual
(package private) SingleSubscriber<? super R>
SingleOnSubscribeMap.MapSubscriber. actual
Methods in rx.internal.operators with parameters of type SingleSubscriber Modifier and Type Method Description void
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, java.lang.Throwable ex)
Constructors in rx.internal.operators with parameters of type SingleSubscriber Constructor Description MapSubscriber(SingleSubscriber<? super R> actual, Func1<? super T,? extends R> mapper)
OnAssemblySingleSubscriber(SingleSubscriber<? super T> actual, java.lang.String stacktrace)
SingleDoAfterTerminateSubscriber(SingleSubscriber<? super T> actual, Action0 action)
-
Uses of SingleSubscriber in rx.internal.util
Fields in rx.internal.util declared as SingleSubscriber Modifier and Type Field Description private SingleSubscriber<? super T>
ScalarSynchronousSingle.ScalarSynchronousSingleAction. subscriber
Methods in rx.internal.util with parameters of type SingleSubscriber Modifier and Type Method Description void
ScalarSynchronousSingle.DirectScheduledEmission. call(SingleSubscriber<? super T> singleSubscriber)
void
ScalarSynchronousSingle.NormalScheduledEmission. call(SingleSubscriber<? super T> singleSubscriber)
Constructors in rx.internal.util with parameters of type SingleSubscriber Constructor Description ScalarSynchronousSingleAction(SingleSubscriber<? super T> subscriber, T value)
-