Top Description Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeThrow<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 type of item (ostensibly) emitted by the Observable
Imports
rx.*, .Observable.OnSubscribe
An Observable that invokes onError when the Observer subscribes to it.

Field Summary

Modifier and TypeField and Description
private final Throwable
exception

Constructor Summary

AccessConstructor and Description
public
OnSubscribeThrow(Throwable exception)

Method Summary

Modifier and TypeMethod and Description
public void
call(Subscriber<? super T>
an Observer of this Observable
observer)

Implements rx.functions.Action1.call.

Accepts an Observer and calls its onError method.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

exceptionback to summary
private final Throwable exception

Constructor Detail

OnSubscribeThrowback to summary
public OnSubscribeThrow(Throwable exception)

Method Detail

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

Implements rx.functions.Action1.call.

Accepts an Observer and calls its onError method.

Parameters
observer:Subscriber<? super T>

an Observer of this Observable

Annotations
@Override