Package rx.internal.operators

Class OnSubscribeOnAssemblySingle<T>

java.lang.Object

rx.internal.operators.OnSubscribeOnAssemblySingle<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

Action, Action1<SingleSubscriber<? super T>>, Function, Single.OnSubscribe<T>

public final class OnSubscribeOnAssemblySingle<T>
extends Object
implements Single.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	OnSubscribeOnAssemblySingle.OnAssemblySingleSubscriber<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 Single.OnSubscribe<T>	source
(package private) final String	stacktrace

Constructor Summary

Constructors

Constructor	Description
OnSubscribeOnAssemblySingle(Single.OnSubscribe<T> source)

Method Summary

Modifier and Type	Method	Description
void	call(SingleSubscriber<? super T> t)

Methods inherited from class java.lang.Object

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

Field Details

source

final Single.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

OnSubscribeOnAssemblySingle

public OnSubscribeOnAssemblySingle(Single.OnSubscribe<T> source)

Method Details

call

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

Specified by:

call in interface Action1<T>