Class OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable<T,R>

java.lang.Object
rx.internal.operators.OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable<T,R>
Type Parameters:
T - the scalar's value type
R - 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 Details

    • value

      final T value
    • mapper

      final Func1<? super T,? extends Iterable<? extends R>> mapper
  • Constructor Details

    • OnSubscribeScalarFlattenIterable

      public OnSubscribeScalarFlattenIterable(T value, Func1<? super T,? extends Iterable<? extends R>> mapper)
  • Method Details