Class OnSubscribeReduceSeed<T,R>

java.lang.Object
rx.internal.operators.OnSubscribeReduceSeed<T,R>
All Implemented Interfaces:
Action, Action1<Subscriber<? super R>>, Function, Observable.OnSubscribe<R>

public final class OnSubscribeReduceSeed<T,R> extends Object implements Observable.OnSubscribe<R>
  • Field Details

    • source

      final Observable<T> source
    • initialValue

      final R initialValue
    • reducer

      final Func2<R,? super T,R> reducer
  • Constructor Details

    • OnSubscribeReduceSeed

      public OnSubscribeReduceSeed(Observable<T> source, R initialValue, Func2<R,? super T,R> reducer)
  • Method Details