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 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 SingleSubscriber Modifier and Type Method Description static voidExceptions. 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 classOnSubscribeOnAssemblySingle.OnAssemblySingleSubscriber<T>(package private) static classSingleDoAfterTerminate.SingleDoAfterTerminateSubscriber<T>(package private) static classSingleOnSubscribeMap.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. actualMethods in rx.internal.operators with parameters of type SingleSubscriber Modifier and Type Method Description voidOnSubscribeOnAssemblySingle. 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, 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. subscriberMethods in rx.internal.util with parameters of type SingleSubscriber Modifier and Type Method Description voidScalarSynchronousSingle.DirectScheduledEmission. call(SingleSubscriber<? super T> singleSubscriber)voidScalarSynchronousSingle.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)
-