public final Class OnSubscribeOnAssemblyCompletable<T>

Captures the current stack when it is instantiated, makes it available through a field and attaches it to all passing exception.

Modifier and Type	Class and Description
pack-priv static class	OnSubscribeOnAssemblyCompletable.OnAssemblyCompletableSubscriber

Modifier and Type

Class and Description

pack-priv static class

OnSubscribeOnAssemblyCompletable.OnAssemblyCompletableSubscriber

Field Summary

Modifier and Type	Field and Description
public static volatile boolean	fullStackTrace If set to true, the creation of PublisherOnAssembly will capture the raw stacktrace instead of the sanitized version.
pack-priv final Completable.OnSubscribe	source
pack-priv final String	stacktrace

Access	Constructor and Description
public	OnSubscribeOnAssemblyCompletable(Completable.OnSubscribe source)

Access

Constructor and Description

public

OnSubscribeOnAssemblyCompletable(Completable.OnSubscribe source)

Modifier and Type	Method and Description
public void	call(CompletableSubscriber t) Implements rx.functions.Action1.call.

Modifier and Type

Method and Description

public void

call(CompletableSubscriber t)

Implements rx.functions.Action1.call.

Field Detail

fullStackTrace	back to summary
public static volatile boolean fullStackTrace If set to true, the creation of PublisherOnAssembly will capture the raw stacktrace instead of the sanitized version.

source	back to summary
pack-priv final Completable.OnSubscribe source

stacktrace	back to summary
pack-priv final String stacktrace

Constructor Detail

OnSubscribeOnAssemblyCompletable	back to summary
public OnSubscribeOnAssemblyCompletable(Completable.OnSubscribe source)

call	back to summary
public void call(CompletableSubscriber t) Implements rx.functions.Action1.call. Annotations @Override

call

back to summary

public void call(CompletableSubscriber t)

Implements rx.functions.Action1.call.

Annotations

@Override

rx.internal.operators back to summary

pack-priv final Class OnSubscribeOnAssemblyCompletable.OnAssemblyCompletableSubscriber

Class Inheritance

extends Object
implements CompletableSubscriber

java.lang.Object
rx.internal.operators.OnSubscribeOnAssemblyCompletable.OnAssemblyCompletableSubscriber

All Implemented Interfaces

rx.CompletableSubscriber

Field Summary

Modifier and Type	Field and Description
pack-priv final CompletableSubscriber	actual
pack-priv final String	stacktrace

Constructor Summary

Access	Constructor and Description
public	OnAssemblyCompletableSubscriber(CompletableSubscriber actual, String stacktrace)

Method Summary

Modifier and Type	Method and Description
public void	onCompleted() Implements rx.CompletableSubscriber.onCompleted. Called once the deferred computation completes normally.
public void	onError(Throwable the exception, not null. e) Implements rx.CompletableSubscriber.onError. Called once if the deferred computation 'throws' an exception.
public void	onSubscribe(Subscription the Subscription instance to call dispose on for cancellation, not null d) Implements rx.CompletableSubscriber.onSubscribe. Called once by the Completable to set a Subscription on this instance which then can be used to cancel the subscription at any time.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

actual	back to summary
pack-priv final CompletableSubscriber actual

stacktrace	back to summary
pack-priv final String stacktrace

Constructor Detail

OnAssemblyCompletableSubscriber	back to summary
public OnAssemblyCompletableSubscriber(CompletableSubscriber actual, String stacktrace)

Method Detail

onCompleted	back to summary
public void onCompleted() Implements rx.CompletableSubscriber.onCompleted. Doc from rx.CompletableSubscriber.onCompleted. Called once the deferred computation completes normally. Annotations @Override

onCompleted

back to summary

public void onCompleted()

Implements rx.CompletableSubscriber.onCompleted.

Doc from rx.CompletableSubscriber.onCompleted.

Called once the deferred computation completes normally.

Annotations

@Override

onError	back to summary
public void onError(Throwable e) Implements rx.CompletableSubscriber.onError. Doc from rx.CompletableSubscriber.onError. Called once if the deferred computation 'throws' an exception. Parameters e:Throwable the exception, not null. Annotations @Override

onError

back to summary

public void onError(Throwable e)

Implements rx.CompletableSubscriber.onError.

Doc from rx.CompletableSubscriber.onError.

Called once if the deferred computation 'throws' an exception.

Parameters

e:Throwable: the exception, not null.

Annotations

@Override

onSubscribe	back to summary
public void onSubscribe(Subscription d) Implements rx.CompletableSubscriber.onSubscribe. Doc from rx.CompletableSubscriber.onSubscribe. Called once by the Completable to set a Subscription on this instance which then can be used to cancel the subscription at any time. Parameters d:Subscription the Subscription instance to call dispose on for cancellation, not null Annotations @Override

onSubscribe

back to summary

public void onSubscribe(Subscription d)

Implements rx.CompletableSubscriber.onSubscribe.

Doc from rx.CompletableSubscriber.onSubscribe.

Called once by the Completable to set a Subscription on this instance which then can be used to cancel the subscription at any time.

Parameters