Top Description Inners Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeOnAssemblySingle<T>

extends Object
implements Single.OnSubscribe<T>
Class Inheritance
All Implemented Interfaces
rx.Single.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Type Parameters
<T>
the value type
Imports
rx.*, rx.exceptions.AssemblyStackTraceException
Captures the current stack when it is instantiated, makes it available through a field and attaches it to all passing exception.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
OnSubscribeOnAssemblySingle.OnAssemblySingleSubscriber<T>

Field Summary

Modifier and TypeField 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 Single.OnSubscribe<T>
source

pack-priv final String
stacktrace

Constructor Summary

AccessConstructor and Description
public
OnSubscribeOnAssemblySingle(Single.OnSubscribe<T> source)

Method Summary

Modifier and TypeMethod and Description
public void
call(SingleSubscriber<? super T> t)

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

fullStackTraceback 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.

sourceback to summary
pack-priv final Single.OnSubscribe<T> source
stacktraceback to summary
pack-priv final String stacktrace

Constructor Detail

OnSubscribeOnAssemblySingleback to summary
public OnSubscribeOnAssemblySingle(Single.OnSubscribe<T> source)

Method Detail

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

Implements rx.functions.Action1.call.

Annotations
@Override
rx.internal.operators back to summary

pack-priv final Class OnSubscribeOnAssemblySingle.OnAssemblySingleSubscriber<T>

extends SingleSubscriber<T>
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final SingleSubscriber<? super T>
actual

pack-priv final String
stacktrace

Constructor Summary

AccessConstructor and Description
public
OnAssemblySingleSubscriber(SingleSubscriber<? super T> actual, String stacktrace)

Method Summary

Modifier and TypeMethod and Description
public void
onError(Throwable
the exception encountered by the Single
e)

Implements abstract rx.SingleSubscriber.onError.

Notifies the SingleSubscriber that the Single has experienced an error condition.
public void
onSuccess(T
the item emitted by the Single
t)

Implements abstract rx.SingleSubscriber.onSuccess.

Notifies the SingleSubscriber with a single item and that the Single has finished sending push-based notifications.
Inherited from rx.SingleSubscriber:
addisUnsubscribedunsubscribe

Field Detail

actualback to summary
pack-priv final SingleSubscriber<? super T> actual
stacktraceback to summary
pack-priv final String stacktrace

Constructor Detail

OnAssemblySingleSubscriberback to summary
public OnAssemblySingleSubscriber(SingleSubscriber<? super T> actual, String stacktrace)

Method Detail

onErrorback to summary
public void onError(Throwable e)

Implements abstract rx.SingleSubscriber.onError.

Doc from rx.SingleSubscriber.onError.

Notifies the SingleSubscriber that the Single has experienced an error condition.

If the Single calls this method, it will not thereafter call onSuccess.

Parameters
e:Throwable

the exception encountered by the Single

Annotations
@Override
onSuccessback to summary
public void onSuccess(T t)

Implements abstract rx.SingleSubscriber.onSuccess.

Doc from rx.SingleSubscriber.onSuccess.

Notifies the SingleSubscriber with a single item and that the Single has finished sending push-based notifications.

The Single will not call this method if it calls onError.

Parameters
t:T

the item emitted by the Single

Annotations
@Override