Package rx.internal.operators

Class OnSubscribeSingle<T>

java.lang.Object

rx.internal.operators.OnSubscribeSingle<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

Action, Action1<SingleSubscriber<? super T>>, Function, Single.OnSubscribe<T>

public class OnSubscribeSingle<T>
extends Object
implements Single.OnSubscribe<T>

Allows conversion of an Observable to a Single ensuring that exactly one item is emitted - no more and no less. Also forwards errors as appropriate.

Field Summary

Fields

Modifier and Type	Field	Description
private final Observable<T>	observable

Constructor Summary

Constructors

Constructor	Description
OnSubscribeSingle(Observable<T> observable)

Method Summary

Modifier and Type	Method	Description
void	call(SingleSubscriber<? super T> child)
static <T> OnSubscribeSingle<T>	create(Observable<T> observable)

Methods inherited from class java.lang.Object

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

Field Details

observable

private final Observable<T> observable

Constructor Details

OnSubscribeSingle

public OnSubscribeSingle(Observable<T> observable)

Method Details

call

public void call(SingleSubscriber<? super T> child)

Specified by:

call in interface Action1<T>

create

public static <T> OnSubscribeSingle<T> create(Observable<T> observable)