Package rx.internal.operators

Class OnSubscribeOnAssemblyCompletable<T>

java.lang.Object

rx.internal.operators.OnSubscribeOnAssemblyCompletable<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

Completable.CompletableOnSubscribe, Action, Action1<Completable.CompletableSubscriber>, Function

public final class OnSubscribeOnAssemblyCompletable<T>
extends Object
implements Completable.CompletableOnSubscribe

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	OnSubscribeOnAssemblyCompletable.OnAssemblyCompletableSubscriber

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 Completable.CompletableOnSubscribe	source
(package private) final String	stacktrace

Constructor Summary

Constructors

Constructor	Description
OnSubscribeOnAssemblyCompletable(Completable.CompletableOnSubscribe source)

Method Summary

Modifier and Type	Method	Description
void	call(Completable.CompletableSubscriber t)

Methods inherited from class java.lang.Object

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

Field Details

source

final Completable.CompletableOnSubscribe 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

OnSubscribeOnAssemblyCompletable

public OnSubscribeOnAssemblyCompletable(Completable.CompletableOnSubscribe source)

Method Details

call

public void call(Completable.CompletableSubscriber t)

Specified by:

call in interface Action1<T>