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 class
OnSubscribeOnAssembly.OnAssemblySubscriber<T>
-
Field Summary
Fields Modifier and Type Field Description static boolean
fullStackTrace
If 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.String
stacktrace
-
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 void
call(Subscriber<? super T> t)
(package private) static java.lang.String
createStacktrace()
-
-
-
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)
-
-