Package rx.internal.operators
Class OnSubscribeOnAssembly<T>
- java.lang.Object
-
- rx.internal.operators.OnSubscribeOnAssembly<T>
-
- Type Parameters:
T- the value type
- All Implemented Interfaces:
Action,Action1<Subscriber<? super T>>,Function,Observable.OnSubscribe<T>
public final class OnSubscribeOnAssembly<T> extends java.lang.Object implements Observable.OnSubscribe<T>
Captures the current stack when it is instantiated, makes it available through a field and attaches it to all passing exception.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static classOnSubscribeOnAssembly.OnAssemblySubscriber<T>
-
Field Summary
Fields Modifier and Type Field Description static booleanfullStackTraceIf set to true, the creation of PublisherOnAssembly will capture the raw stacktrace instead of the sanitized version.(package private) Observable.OnSubscribe<T>source(package private) java.lang.Stringstacktrace
-
Constructor Summary
Constructors Constructor Description OnSubscribeOnAssembly(Observable.OnSubscribe<T> source)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcall(Subscriber<? super T> t)(package private) static java.lang.StringcreateStacktrace()
-
-
-
Field Detail
-
source
final Observable.OnSubscribe<T> source
-
stacktrace
final java.lang.String stacktrace
-
fullStackTrace
public static volatile boolean fullStackTrace
If set to true, the creation of PublisherOnAssembly will capture the raw stacktrace instead of the sanitized version.
-
-
Constructor Detail
-
OnSubscribeOnAssembly
public OnSubscribeOnAssembly(Observable.OnSubscribe<T> source)
-
-
Method Detail
-
createStacktrace
static java.lang.String createStacktrace()
-
call
public void call(Subscriber<? super T> t)
-
-