Package rx.internal.operators
Class OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable<T,R>
java.lang.Object
rx.internal.operators.OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable<T,R>
- Type Parameters:
T
- the scalar's value typeR
- the result value type
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super R>>
,Function
,Observable.OnSubscribe<R>
- Enclosing class:
OnSubscribeFlattenIterable<T,
R>
static final class OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable<T,R>
extends Object
implements Observable.OnSubscribe<R>
A custom flattener that works from a scalar value and computes the iterable
during subscription time.
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary