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 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 final 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) final Observable.OnSubscribe<T>	source
(package private) final String	stacktrace

Constructor Summary

Constructors

Constructor	Description
OnSubscribeOnAssembly(Observable.OnSubscribe<T> source)

Method Summary

Modifier and Type	Method	Description
void	call(Subscriber<? super T> t)
(package private) static String	createStacktrace()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

source

final Observable.OnSubscribe<T> source

stacktrace

final 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 Details

OnSubscribeOnAssembly

public OnSubscribeOnAssembly(Observable.OnSubscribe<T> source)

Method Details

createStacktrace

static String createStacktrace()

call

public void call(Subscriber<? super T> t)

Specified by:

call in interface Action1<T>