public Class OnSubscribeSingle<T>

Class Inheritance

extends Object
implements Single.OnSubscribe<T>

All Implemented Interfaces

Type Parameters

Imports

java.util.NoSuchElementException, rx.*

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

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

Access	Constructor and Description
public	OnSubscribeSingle(Observable<T> observable)

Modifier and Type	Method and Description
public void	call(final SingleSubscriber<? super T> child) Implements rx.functions.Action1.call.
public static <T> OnSubscribeSingle<T>	create(Observable<T> observable)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

observable	back to summary
private final Observable<T> observable

OnSubscribeSingle	back to summary
public OnSubscribeSingle(Observable<T> observable)

call	back to summary
public void call(final SingleSubscriber<? super T> child) Implements rx.functions.Action1.call. Annotations @Override

call

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

Annotations

create	back to summary
public static <T> OnSubscribeSingle<T> create(Observable<T> observable)