Package rx.internal.operators

Class OnSubscribeFromIterable<T>

java.lang.Object

rx.internal.operators.OnSubscribeFromIterable<T>

Type Parameters:

T - the value type of the items

All Implemented Interfaces:

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

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

Converts an Iterable sequence into an Observable.

You can convert any object that supports the Iterable interface into an Observable that emits each item in the object, with the toObservable operation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	OnSubscribeFromIterable.IterableProducer<T>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Iterable<? extends T>	is

Constructor Summary

Constructors

Constructor	Description
OnSubscribeFromIterable(Iterable<? extends T> iterable)

Method Summary

Modifier and Type	Method	Description
void	call(Subscriber<? super T> o)

Methods inherited from class java.lang.Object

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

Field Details

is

final Iterable<? extends T> is

Constructor Details

OnSubscribeFromIterable

public OnSubscribeFromIterable(Iterable<? extends T> iterable)

Method Details

call

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

Specified by:

call in interface Action1<T>