Package rx.internal.operators

Class OnSubscribeThrow<T>

java.lang.Object

rx.internal.operators.OnSubscribeThrow<T>

Type Parameters:

T - the type of item (ostensibly) emitted by the Observable

All Implemented Interfaces:

Action, Action1<Subscriber<? super T>>, Function, Observable.OnSubscribe<T>

public final class OnSubscribeThrow<T>
extends Object
implements Observable.OnSubscribe<T>

An Observable that invokes onError when the Observer subscribes to it.

Field Summary

Fields

Modifier and Type	Field	Description
private final Throwable	exception

Constructor Summary

Constructors

Constructor	Description
OnSubscribeThrow(Throwable exception)

Method Summary

Modifier and Type	Method	Description
void	call(Subscriber<? super T> observer)	Accepts an Observer and calls its onError method.

Methods inherited from class java.lang.Object

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

Field Details

exception

private final Throwable exception

Constructor Details

OnSubscribeThrow

public OnSubscribeThrow(Throwable exception)

Method Details

call

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

Accepts an Observer and calls its onError method.

Specified by:

call in interface Action1<T>

Parameters:

observer - an Observer of this Observable