Top Description Inners Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeOnAssembly<T>

extends Object
implements Observable.OnSubscribe<T>
Class Inheritance
All Implemented Interfaces
rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Type Parameters
<T>
the value type
Imports
rx.Observable.OnSubscribe, .Subscriber, 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
OnSubscribeOnAssembly.OnAssemblySubscriber<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 Observable.OnSubscribe<T>
source

pack-priv final String
stacktrace

Constructor Summary

AccessConstructor and Description
public
OnSubscribeOnAssembly(Observable.OnSubscribe<T> source)

Method Summary

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

Implements rx.functions.Action1.call.

pack-priv static String
createStacktrace()

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 Observable.OnSubscribe<T> source
stacktraceback to summary
pack-priv final String stacktrace

Constructor Detail

OnSubscribeOnAssemblyback to summary
public OnSubscribeOnAssembly(Observable.OnSubscribe<T> source)

Method Detail

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

Implements rx.functions.Action1.call.

Annotations
@Override
createStacktraceback to summary
pack-priv static String createStacktrace()
rx.internal.operators back to summary

pack-priv final Class OnSubscribeOnAssembly.OnAssemblySubscriber<T>

extends Subscriber<T>
Class Inheritance

Field Summary

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

pack-priv final String
stacktrace

Constructor Summary

AccessConstructor and Description
public
OnAssemblySubscriber(Subscriber<? super T> actual, String stacktrace)

Method Summary

Modifier and TypeMethod and Description
public void
onCompleted()

Implements rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.
public void
onError(Throwable
the exception encountered by the Observable
e)

Implements rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.
public void
onNext(T
the item emitted by the Observable
t)

Implements rx.Observer.onNext.

Provides the Observer with a new item to observe.
Inherited from rx.Subscriber:
addisUnsubscribedonStartrequestsetProducerunsubscribe

Field Detail

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

Constructor Detail

OnAssemblySubscriberback to summary
public OnAssemblySubscriber(Subscriber<? super T> actual, String stacktrace)

Method Detail

onCompletedback to summary
public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.

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

Annotations
@Override
onErrorback to summary
public void onError(Throwable e)

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onCompleted.

Parameters
e:Throwable

the exception encountered by the Observable

Annotations
@Override
onNextback to summary
public void onNext(T t)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onCompleted or onError.

Parameters
t:T

the item emitted by the Observable

Annotations
@Override