Modifier and Type	Class and Description
pack-priv static class	OnSubscribeFlattenIterable.FlattenIterableSubscriber<T, R>
pack-priv static class	OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable< the scalar's value type T, the result value type R> A custom flattening operator that works from a scalar value and computes the iterable during subscription time.

Access	Constructor and Description
protected	OnSubscribeFlattenIterable(Observable<? extends T> source, Func1<? super T, ? extends Iterable<? extends R>> mapper, int prefetch) Protected: use createFrom to handle source-dependent optimizations.

mapper	back to summary
pack-priv final Func1<? super T, ? extends Iterable<? extends R>> mapper

prefetch	back to summary
pack-priv final int prefetch

source	back to summary
pack-priv final Observable<? extends T> source

OnSubscribeFlattenIterable	back to summary
protected OnSubscribeFlattenIterable(Observable<? extends T> source, Func1<? super T, ? extends Iterable<? extends R>> mapper, int prefetch) Protected: use createFrom to handle source-dependent optimizations.

call	back to summary
public void call(Subscriber<? super R> t) Implements rx.functions.Action1.call. Annotations @Override

createFrom	back to summary
public static <T, R> Observable<R> createFrom(Observable<? extends T> source, Func1<? super T, ? extends Iterable<? extends R>> mapper, int prefetch)

pack-priv final Class OnSubscribeFlattenIterable.FlattenIterableSubscriber<T, R>

Class Inheritance

java.lang.Object
rx.Subscriber
rx.internal.operators.OnSubscribeFlattenIterable.FlattenIterableSubscriber

Field Summary

Modifier and Type	Field and Description
pack-priv Iterator<? extends R>	active
pack-priv final Subscriber<? super R>	actual
pack-priv volatile boolean	done
pack-priv final AtomicReference<Throwable>	error
pack-priv final long	limit
pack-priv final Func1<? super T, ? extends Iterable<? extends R>>	mapper
pack-priv long	produced
pack-priv final Queue<Object>	queue
pack-priv final AtomicLong	requested Hides rx.Subscriber.requested.
pack-priv final AtomicInteger	wip

Constructor Summary

Access	Constructor and Description
public	FlattenIterableSubscriber(Subscriber<? super R> actual, Func1<? super T, ? extends Iterable<? extends R>> mapper, int prefetch)

Method Summary

Modifier and Type	Method and Description
pack-priv boolean	checkTerminated(boolean d, boolean empty, Subscriber<?> a, Queue<?> q)
pack-priv void	drain()
public void	onCompleted() Implements rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications.
public void	onError(Throwable the exception encountered by the Observable e) Implements rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public void	onNext(T the item emitted by the Observable t) Implements rx.Observer.onNext. Provides the Observer with a new item to observe.
pack-priv void	requestMore(long n)

Inherited from rx.Subscriber:: add isUnsubscribed onStart request setProducer unsubscribe

Field Detail

active	back to summary
pack-priv Iterator<? extends R> active

actual	back to summary
pack-priv final Subscriber<? super R> actual

done	back to summary
pack-priv volatile boolean done

error	back to summary
pack-priv final AtomicReference<Throwable> error

limit	back to summary
pack-priv final long limit

mapper	back to summary
pack-priv final Func1<? super T, ? extends Iterable<? extends R>> mapper

produced	back to summary
pack-priv long produced

queue	back to summary
pack-priv final Queue<Object> queue

requested	back to summary
pack-priv final AtomicLong requested Hides rx.Subscriber.requested.

wip	back to summary
pack-priv final AtomicInteger wip

Constructor Detail

FlattenIterableSubscriber	back to summary
public FlattenIterableSubscriber(Subscriber<? super R> actual, Func1<? super T, ? extends Iterable<? extends R>> mapper, int prefetch)

Method Detail

checkTerminated	back to summary
pack-priv boolean checkTerminated(boolean d, boolean empty, Subscriber<?> a, Queue<?> q)

drain	back to summary
pack-priv void drain()

onCompleted back to summary

onCompleted	back to summary
public void onCompleted() Implements rx.Observer.onCompleted. Doc from rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications. The `Observable` will not call this method if it calls `onError`. Annotations @Override

public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls onError.

Annotations

@Override

onError back to summary

onError	back to summary
public void onError(Throwable e) Implements rx.Observer.onError. Doc from rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition. If the `Observable` calls this method, it will not thereafter call `onNext` or `onCompleted`. Parameters e:Throwable the exception encountered by the Observable Annotations @Override

public void onError(Throwable e)

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onCompleted.

Parameters

e:Throwable: the exception encountered by the Observable

Annotations

@Override

onNext back to summary

onNext	back to summary
public void onNext(T t) Implements rx.Observer.onNext. Doc from rx.Observer.onNext. Provides the Observer with a new item to observe. The `Observable` may call this method 0 or more times. The `Observable` will not call this method again after it calls either `onCompleted` or `onError`. Parameters t:T the item emitted by the Observable Annotations @Override

public void onNext(T t)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onCompleted or onError.

Parameters

t:T: the item emitted by the Observable

Annotations

@Override

requestMore	back to summary
pack-priv void requestMore(long n)

rx.internal.operators back to summary

pack-priv final Class OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable<T, R>

Class Inheritance

extends Object
implements Observable.OnSubscribe<R>

java.lang.Object
rx.internal.operators.OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable

All Implemented Interfaces

rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function

Type Parameters

<T>: the scalar's value type
<R>: the result value type

A custom flattening operator that works from a scalar value and computes the iterable during subscription time.

Field Summary

Modifier and Type	Field and Description
pack-priv final Func1<? super T, ? extends Iterable<? extends R>>	mapper
pack-priv final T	value

Constructor Summary

Access	Constructor and Description
public	OnSubscribeScalarFlattenIterable(T value, Func1<? super T, ? extends Iterable<? extends R>> mapper)

Method Summary

Modifier and Type	Method and Description
public void	call(Subscriber<? super R> t) Implements rx.functions.Action1.call.

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

Field Detail

mapper	back to summary
pack-priv final Func1<? super T, ? extends Iterable<? extends R>> mapper

value	back to summary
pack-priv final T value

Constructor Detail

OnSubscribeScalarFlattenIterable	back to summary
public OnSubscribeScalarFlattenIterable(T value, Func1<? super T, ? extends Iterable<? extends R>> mapper)

Method Detail

call	back to summary
public void call(Subscriber<? super R> t) Implements rx.functions.Action1.call. Annotations @Override

call

back to summary

public void call(Subscriber<? super R> t)

Implements rx.functions.Action1.call.

Annotations

@Override

public final Class OnSubscribeFlattenIterable<T, R>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OnSubscribeFlattenIterable.FlattenIterableSubscriber<T, R>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable<T, R>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

Modifier and Type	Field and Description
pack-priv final Func1<? super T, ? extends Iterable<? extends R>>	mapper
pack-priv final int	prefetch
pack-priv final Observable<? extends T>	source

Modifier and Type	Method and Description
public void	call(Subscriber<? super R> t) Implements rx.functions.Action1.call.
public static <T, R> Observable<R>	createFrom(Observable<? extends T> source, Func1<? super T, ? extends Iterable<? extends R>> mapper, int prefetch)