Class OnSubscribeCollect<T,R>

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

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

    • source

      final Observable<T> source
    • collectionFactory

      final Func0<R> collectionFactory
    • collector

      final Action2<R,? super T> collector
  • Constructor Details

    • OnSubscribeCollect

      public OnSubscribeCollect(Observable<T> source, Func0<R> collectionFactory, Action2<R,? super T> collector)
  • Method Details